compact1, compact2, compact3

java.util.concurrent

Class ForkJoinWorkerThread

java.lang.Object

java.lang.Thread

java.util.concurrent.ForkJoinWorkerThread

All Implemented Interfaces:

Runnable

public class ForkJoinWorkerThread
extends Thread

一个线程的 ForkJoinPool管理，执行 ForkJoinTasks。这类生子类专为增加功能的缘故，没有可重写的方法处理调度或执行。但是，可以重写主任务处理循环的初始化和终止方法。如果你创建一个类，你还需要去 use it在 ForkJoinPool供应定制 ForkJoinPool.ForkJoinWorkerThreadFactory。

从以下版本开始：

一点七

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

构造方法摘要

构造方法

Modifier	Constructor and Description
protected	ForkJoinWorkerThread(ForkJoinPool pool) 创建一个forkjoinworkerthread在给定池操作。

方法摘要

Modifier and Type	Method and Description
ForkJoinPool	getPool() 返回托管该线程的池。
int	getPoolIndex() 返回该线程在其池中的唯一索引号。
protected void	onStart() 初始化内部状态，施工后但在处理任何任务。
protected void	onTermination(Throwable exception) 执行与终止此工人线程相关联的清理工作。
void	run() 这种方法必须是公开的，但不应该被显式调用。

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

ForkJoinWorkerThread

protected ForkJoinWorkerThread(ForkJoinPool pool)

创建一个forkjoinworkerthread在给定池操作。

参数

pool这个线程池中

异常

NullPointerException如果池是空的

方法详细信息

getPool

public ForkJoinPool getPool()

返回托管该线程的池。

结果

游泳池

getPoolIndex

public int getPoolIndex()

返回该线程在其池中的唯一索引号。返回的值范围从零到线程的最大数目（减一），可能存在于池中，并在线程的生命期内不会改变。此方法可能是有用的应用程序，跟踪状态或收集结果，每名工人的线程，而不是每一项任务。

结果

指数

onStart

protected void onStart()

初始化内部状态，施工后但在处理任何任务。如果你重写这个方法，你必须调用 super.onStart()在方法的开始。初始化需要关心：大多数字段必须具有合法的默认值，以确保其他线程的尝试访问正确工作，即使在这个线程开始处理任务之前。

onTermination

protected void onTermination(Throwable exception)

执行与终止此工人线程相关联的清理工作。如果你重写这个方法，你必须调用 super.onTermination在重写的方法结束。

参数

exception导致该线程中止由于不可恢复的错误外，或 null如果完成正常

run

public void run()

这种方法必须是公开的，但不应该被显式调用。它执行执行 ForkJoinTasks主运行循环。

Specified by:

run 接口 Runnable

重写：

run 方法重写，继承类 Thread

另请参见：

Thread.start()， Thread.stop()， Thread.Thread(ThreadGroup, Runnable, String)