java.util.concurrent

クラス ForkJoinWorkerThread

java.lang.Object

java.lang.Thread

java.util.concurrent.ForkJoinWorkerThread

すべての実装されたインタフェース:

Runnable

public class ForkJoinWorkerThread
extends Thread

ForkJoinPool によって管理されるスレッドであり、ForkJoinTask を実行します。このクラスは、機能の追加のためにのみサブクラス化可能です。スケジューリングまたは実行を扱うオーバーライド可能なメソッドはありません。ただし、メインのタスク処理ループを囲む初期化および終了メソッドはオーバーライドできます。このようなサブクラスを作成する場合は、カスタムの 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, 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

クラス java.lang.Object から継承されたメソッド

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

コンストラクタの詳細

ForkJoinWorkerThread

protected ForkJoinWorkerThread(ForkJoinPool pool)

指定されたプール内で動作している ForkJoinWorkerThread を作成します。

パラメータ:

pool - このスレッドが機能しているプール

例外:

NullPointerException - プールが 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 を実行します。

定義:

run、インタフェース: Runnable

オーバーライド:

run、クラス: Thread

関連項目:

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