Class MultiThreadRunner

java.lang.Object

tech.riemann.nif.utils.thread.MultiThreadRunner

Direct Known Subclasses:

CountdownMultiThreadRunner

public class MultiThreadRunner
extends Object

多线程执行器基类

该类提供了一个基础框架，用于通过多个线程并行执行作业

主要功能是启动指定数量的线程来执行给定的JobRunner任务

子类可以通过继承此类并添加特定的同步机制来实现更复杂的多线程执行逻辑

Author:

Kerbores(kerbores@riemann.tech)

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MultiThreadRunner.RunThread	执行线程类，继承自Thread

Constructor Summary

Constructors

Constructor	Description
MultiThreadRunner()

Method Summary

Modifier and Type	Method	Description
void	run(JobRunner jobRunner, int threads)	使用指定数量的线程来启动作业运行器

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MultiThreadRunner

public MultiThreadRunner()

Method Details

run

public void run(JobRunner jobRunner,
 int threads)
         throws InterruptedException

使用指定数量的线程来启动作业运行器

Parameters:

jobRunner - 作业运行器实例，表示需要执行的作业

threads - 线程数量，表示要启动的线程数以并行执行作业

Throws:

InterruptedException - 如果在启动线程过程中发生中断异常