- java.lang.Object
-
- java.lang.Thread
-
- java.util.concurrent.ForkJoinWorkerThread
-
- 实现的所有接口
-
Runnable
public class ForkJoinWorkerThread extends Thread
由ForkJoinPool
管理的线程,执行ForkJoinTask
。 这个类只是为了增加功能而可子类化 - 没有可覆盖的方法来处理调度或执行。 但是,您可以覆盖主任务处理循环周围的初始化和终止方法。 如果您确实创建了这样的子类,则还需要在ForkJoinPool中提供自定义ForkJoinPool.ForkJoinWorkerThreadFactory
到ForkJoinPool
。- 从以下版本开始:
- 1.7
-
-
嵌套类汇总
-
嵌套类/接口声明在类 java.lang.Thread
Thread.State, Thread.UncaughtExceptionHandler
-
-
字段汇总
-
声明的属性在类 java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
-
-
构造方法摘要
构造方法 变量 构造器 描述 protected
ForkJoinWorkerThread(ForkJoinPool pool)
创建在给定池中运行的ForkJoinWorkerThread。
-
方法摘要
所有方法 实例方法 具体的方法 变量和类型 方法 描述 ForkJoinPool
getPool()
返回托管此线程的池。int
getPoolIndex()
返回其池中此线程的唯一索引号。protected void
onStart()
在构造之后但在处理任何任务之前初始化内部状态。protected void
onTermination(Throwable exception)
执行与此工作线程终止相关的清理。void
run()
此方法必须是公共的,但绝不应该显式调用。-
声明方法的类 java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
-
-
-
-
构造方法详细信息
-
ForkJoinWorkerThread
protected ForkJoinWorkerThread(ForkJoinPool pool)
创建在给定池中运行的ForkJoinWorkerThread。- 参数
-
pool
- 此主题pool
的池 - 异常
-
NullPointerException
- 如果pool为null
-
-
方法详细信息
-
getPool
public ForkJoinPool getPool()
返回托管此线程的池。- 结果
- 游泳池
-
getPoolIndex
public int getPoolIndex()
返回其池中此线程的唯一索引号。 返回值的范围从0到池中可能存在的最大线程数(减1),并且在线程的生存期内不会更改。 对于跟踪状态或收集每个工作线程而不是每个任务的结果的应用程序,此方法可能很有用。- 结果
- 索引号
-
onStart
protected void onStart()
在构造之后但在处理任何任务之前初始化内部状态。 如果重写此方法,则必须在方法开头调用super.onStart()
。 初始化需要小心:大多数字段必须具有合法的默认值,以确保即使在此线程开始处理任务之前,来自其他线程的尝试访问也能正常工作。
-
onTermination
protected void onTermination(Throwable exception)
执行与此工作线程终止相关的清理。 如果重写此方法,则必须在重写方法的末尾调用super.onTermination
。- 参数
-
exception
- 导致此线程因不可恢复的错误而中止的异常,或者null
如果正常完成)
-
run
public void run()
此方法必须是公共的,但绝不应该显式调用。 它执行主运行循环以执行ForkJoinTask
。- Specified by:
-
run
在界面Runnable
- 重写:
-
run
类Thread
- 另请参见:
-
Thread.start()
,Thread.stop()
,Thread(ThreadGroup, Runnable, String)
-
-