java.util.concurrent

クラス ForkJoinPool

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ForkJoinPool

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

Executor、ExecutorService

public class ForkJoinPool
extends AbstractExecutorService

ForkJoinTask を実行するための ExecutorService。ForkJoinPool は、ForkJoinTask 以外のクライアントからの送信のほか、管理および監視操作のためのエントリポイントを提供します。

ForkJoinPool は、主に work-stealing を使用する点で、ほかの種類の ExecutorService とは異なります。プール内のすべてのスレッドが、ほかのアクティブなタスクによって作成されたサブタスクを見つけて実行しようとします (1 つも存在しない場合は、最終的に作業の待機がブロックされます)。これにより、ほとんどのタスクがほかのサブタスクを生成する場合の効率的な処理が可能になります (ほとんどの ForkJoinTask も同様です)。コンストラクタで asyncMode を true に設定する場合は、ForkJoinPool もまた、結合されることのないイベント形式のタスクでの使用に適している可能性があります。

ForkJoinPool は、デフォルトでは使用可能なプロセッサの数に等しい、特定のターゲット並列性レベルで構築されます。このプールは、一部のタスクがほかのタスクの結合を待機して停止している場合でも、内部ワーカースレッドを動的に追加、中断、または再開することによって、十分な数のアクティブな (または使用可能な) スレッドを維持しようとします。ただし、ブロックされた入出力やその他の管理されていない同期が存在する場合、このような調整は保証されません。ネストされた ForkJoinPool.ManagedBlocker インタフェースを使用すると、対応可能な同期の種類を拡張できます。

実行およびライフサイクル制御メソッドに加えて、このクラスは、分岐/結合アプリケーションの開発、チューニング、および監視を支援することを目的にしたステータスチェックメソッド (たとえば getStealCount()) を提供します。また、toString() メソッドも、プール状態の指示を非公式の監視に便利な形式で返します。

ほかの ExecutorService と同様に、次の表に要約されている 3 つの主なタスク実行メソッドがあります。これらは、まだ現在のプール内の分岐/結合計算に関与していないクライアントによって使用されるように設計されています。これらのメソッドのメインの形式は ForkJoinTask のインスタンスを受け入れますが、オーバーロードされた形式では、プレーンな Runnable または Callable ベースのアクティビティーの混在実行も許可されます。ただし、すでにプール内で実行されているタスクは通常、これらのプール実行メソッドを使用するべきではなく、代わりにこの表に示されている計算内の形式を使用してください。

	分岐/結合以外のクライアントからの呼び出し	分岐/結合計算内からの呼び出し
非同期実行の調整	execute(ForkJoinTask)	ForkJoinTask.fork()
結果の待機および取得	invoke(ForkJoinTask)	ForkJoinTask.invoke()
実行の調整および Future の取得	submit(ForkJoinTask)	ForkJoinTask.fork() (ForkJoinTask は Future)

使用例。 通常は、プログラムまたはサブシステム内のすべての並列タスク実行のために 1 つの ForkJoinPool が使用されます。それ以外の使用は一般に、大量のスレッドを作成する場合の構築や登録のオーバーヘッドより重要とは言えません。たとえば、RecursiveAction で示されている SortTasks には一般的なプールを使用できます。ForkJoinPool はスレッドをデーモンモードで使用するため、通常、プログラムの終了時にこのようなプールに対して明示的に shutdown を実行する必要はありません。

 static final ForkJoinPool mainPool = new ForkJoinPool();
 ...
 public void sort(long[] array) {
   mainPool.invoke(new SortTask(array, 0, array.length));
 }
 

実装上の注意: この実装では、実行中のスレッドの最大数を 32767 に制限します。 最大数を超えるプールを作成しようとすると、IllegalArgumentException が発生します。

この実装では、送信されたタスクを (RejectedExecutionException をスローすることによって) 拒否するのは、プールがシャットダウンされているか、または内部リソースが使い果たされた場合だけです。

導入されたバージョン:

1.7

ネストされたクラスのサマリー

ネストされたクラス

修飾子と型	クラスと説明
static interface	ForkJoinPool.ForkJoinWorkerThreadFactory 新しい ForkJoinWorkerThread を作成するためのファクトリです。
static interface	ForkJoinPool.ManagedBlocker ForkJoinPool 内で実行中のタスクについての管理対象の並列性を拡張するためのインタフェースです。

フィールドのサマリー

フィールド

修飾子と型	フィールドと説明
static ForkJoinPool.ForkJoinWorkerThreadFactory	defaultForkJoinWorkerThreadFactory 新しい ForkJoinWorkerThread を作成します。

コンストラクタのサマリー

コンストラクタ

コンストラクタと説明
ForkJoinPool() 並列性が Runtime.availableProcessors() と等しく、デフォルトのスレッドファクトリを使用し、UncaughtExceptionHandler を指定せず、非同期 LIFO 処理モードを使用して ForkJoinPool を作成します。
ForkJoinPool(int parallelism) 指定された並列性レベルを持ち、デフォルトのスレッドファクトリを使用し、UncaughtExceptionHandler を指定せず、非同期 LIFO 処理モードを使用して ForkJoinPool を作成します。
ForkJoinPool(int parallelism, ForkJoinPool.ForkJoinWorkerThreadFactory factory, Thread.UncaughtExceptionHandler handler, boolean asyncMode) 指定されたパラメータを使って ForkJoinPool を作成します。

メソッドのサマリー

メソッド

修飾子と型	メソッドと説明
boolean	awaitTermination(long timeout, TimeUnit unit) シャットダウン要求後にすべてのタスクが実行を完了していたか、タイムアウトが発生するか、現在のスレッドで割り込みが発生するか、そのいずれかが最初に発生するまでブロックします。
protected int	drainTasksTo(Collection<? super ForkJoinTask<?>> c) 実行されなかった、送信およびフォークされた使用可能なすべてのタスクをスケジュールキューから削除し、実行ステータスを変更せずにそれらを指定されたコレクションに追加します。
void	execute(ForkJoinTask<?> task) 指定されたタスクの (非同期) 実行を調整します。
void	execute(Runnable task) 将来のどの時点かで、指定されたコマンドを実行します。
int	getActiveThreadCount() 現在タスクを横取りまたは実行しているスレッドの推定数を返します。
boolean	getAsyncMode() 結合されないフォークされたタスクについて、このプールがローカルの先入れ先出しスケジュールモードを使用している場合、true を返します。
ForkJoinPool.ForkJoinWorkerThreadFactory	getFactory() 新規ワーカーの構築に使用されるファクトリを返します。
int	getParallelism() このプールのターゲット並列性レベルを返します。
int	getPoolSize() 開始したがまだ終了していないワーカースレッド数を返します。
int	getQueuedSubmissionCount() このプールに送信された、まだ実行が開始されていないタスクの推定数を返します。
long	getQueuedTaskCount() ワーカースレッドによって現在キューに保持されているタスクの総数の推定値を返します (プールに送信された、まだ開始されていないタスクは含まない)。
int	getRunningThreadCount() タスクの結合またはその他の管理対象同期の待機をブロックしない、ワーカースレッドの推定数を返します。
long	getStealCount() 1 つのスレッドのワークキューから別のスレッドによって横取りされたタスクの総数の推定値を返します。
Thread.UncaughtExceptionHandler	getUncaughtExceptionHandler() タスクを実行中に発生した回復不能なエラーが原因で終了した内部ワーカースレッド用のハンドラを返します。
boolean	hasQueuedSubmissions() このプールに送信された、まだ実行が開始されていないタスクがある場合は true を返します。
<T> T	invoke(ForkJoinTask<T> task) 指定されたタスクを実行し、完了時にその結果を返します。
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks) 指定されたタスクを実行し、すべて完了すると、ステータスと結果を含む Future のリストを返します。
boolean	isQuiescent() すべてのワーカースレッドが現在アイドル状態の場合に true を返します。
boolean	isShutdown() このプールがシャットダウンしていた場合、true を返します。
boolean	isTerminated() シャットダウンに続いてすべてのタスクが完了していた場合、true を返します。
boolean	isTerminating() 終了処理が開始されたがまだ完了していない場合、true を返します。
static void	managedBlock(ForkJoinPool.ManagedBlocker blocker) 指定されたブロッカに合わせてブロックします。
protected <T> RunnableFuture<T>	newTaskFor(Callable<T> callable) 指定された呼び出し可能タスクの RunnableFuture を返します。
protected <T> RunnableFuture<T>	newTaskFor(Runnable runnable, T value) 指定された実行可能タスクおよびデフォルト値の RunnableFuture を返します。
protected ForkJoinTask<?>	pollSubmission() まだ実行されていない次の送信が使用可能な場合、それを削除して復帰します。
void	shutdown() 順序正しくシャットダウンを開始します。以前に送信されたタスクが実行されますが、新規タスクは受け入れられません。
List<Runnable>	shutdownNow() すべてのタスクの取り消しまたは停止を行い、あとで送信されたすべてのタスクを拒否することを試みます。
<T> ForkJoinTask<T>	submit(Callable<T> task) 値を返す実行用タスクを送信して、保留状態のタスク結果を表す Future を返します。
<T> ForkJoinTask<T>	submit(ForkJoinTask<T> task) 実行用の ForkJoinTask を送信します。
ForkJoinTask<?>	submit(Runnable task) 実行用の Runnable タスクを送信し、そのタスクを表す Future を返します。
<T> ForkJoinTask<T>	submit(Runnable task, T result) 実行用の Runnable タスクを送信し、そのタスクを表す Future を返します。
String	toString() 実行状態、並列性レベル、およびワーカーおよびタスクカウントの指示を含めて、このプールおよびその状態を識別する文字列を返します。

クラス java.util.concurrent.AbstractExecutorService から継承されたメソッド

invokeAll, invokeAny, invokeAny

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

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

フィールドの詳細

defaultForkJoinWorkerThreadFactory

public static final ForkJoinPool.ForkJoinWorkerThreadFactory defaultForkJoinWorkerThreadFactory

新しい ForkJoinWorkerThread を作成します。このファクトリは、ForkJoinPool コンストラクタでオーバーライドされないかぎり使用されます。

コンストラクタの詳細

ForkJoinPool

public ForkJoinPool()

並列性が Runtime.availableProcessors() と等しく、デフォルトのスレッドファクトリを使用し、UncaughtExceptionHandler を指定せず、非同期 LIFO 処理モードを使用して ForkJoinPool を作成します。

例外:

SecurityException - セキュリティーマネージャーが存在し、呼び出し元が RuntimePermission("modifyThread") を持たないためスレッドを変更できない場合

ForkJoinPool

public ForkJoinPool(int parallelism)

指定された並列性レベルを持ち、デフォルトのスレッドファクトリを使用し、UncaughtExceptionHandler を指定せず、非同期 LIFO 処理モードを使用して ForkJoinPool を作成します。

パラメータ:

parallelism - 並列性レベル

例外:

IllegalArgumentException - 並列性がゼロ以下か、実装限界より大きい

SecurityException - セキュリティーマネージャーが存在し、呼び出し元が RuntimePermission("modifyThread") を持たないためスレッドを変更できない場合

ForkJoinPool

public ForkJoinPool(int parallelism,
            ForkJoinPool.ForkJoinWorkerThreadFactory factory,
            Thread.UncaughtExceptionHandler handler,
            boolean asyncMode)

指定されたパラメータを使って ForkJoinPool を作成します。

パラメータ:

parallelism - 並列性レベル。デフォルト値の場合、Runtime.availableProcessors() を使用します。

factory - 新しいスレッドを作成するためのファクトリ。デフォルト値の場合、defaultForkJoinWorkerThreadFactory を使用します。

handler - タスクの実行中に検出された回復不可能なエラーのために終了する内部ワーカースレッドのためのハンドラ。デフォルト値の場合、null を使用します。

asyncMode - true の場合は、結合されないフォークされたタスクに対して、ローカルの先入れ先出しスケジュールモードを確立する。このモードは、ワーカースレッドがイベント形式の非同期タスクのみを処理するアプリケーションでは、デフォルトのローカルのスタックベースモードより適している場合がある。デフォルト値の場合、false を使用します。

例外:

IllegalArgumentException - 並列性がゼロ以下か、実装限界より大きい

NullPointerException - ファクトリが null の場合

SecurityException - セキュリティーマネージャーが存在し、呼び出し元が RuntimePermission("modifyThread") を持たないためスレッドを変更できない場合

メソッドの詳細

invoke

public <T> T invoke(ForkJoinTask<T> task)

指定されたタスクを実行し、完了時にその結果を返します。計算で非チェック例外またはエラーが発生した場合は、それが、この呼び出しの結果として再スローされます。再スローされた例外は通常の例外と同じように動作しますが、可能な場合は、現在のスレッドと実際に例外が発生しているスレッドの両方 (最小限としては後者のみ) の (たとえば、ex.printStackTrace() を使用して表示された) スタックトレースを含みます。

パラメータ:

task - タスク

戻り値:

タスクの結果

例外:

NullPointerException - タスクが null の場合

RejectedExecutionException - タスクの実行をスケジュールできない場合

execute

public void execute(ForkJoinTask<?> task)

指定されたタスクの (非同期) 実行を調整します。

パラメータ:

task - タスク

例外:

NullPointerException - タスクが null の場合

RejectedExecutionException - タスクの実行をスケジュールできない場合

execute

public void execute(Runnable task)

インタフェースからコピーされた説明: Executor

将来のどの時点かで、指定されたコマンドを実行します。コマンドは、新規スレッド内でも、プールされたスレッド内でも、呼び出し側のスレッド内でも、Executor 実装により随意に実行できます。

パラメータ:

task - 実行可能なタスク

例外:

NullPointerException - タスクが null の場合

RejectedExecutionException - タスクの実行をスケジュールできない場合

submit

public <T> ForkJoinTask<T> submit(ForkJoinTask<T> task)

実行用の ForkJoinTask を送信します。

パラメータ:

task - 送信するタスク

戻り値:

タスク

例外:

NullPointerException - タスクが null の場合

RejectedExecutionException - タスクの実行をスケジュールできない場合

submit

public <T> ForkJoinTask<T> submit(Callable<T> task)

インタフェースからコピーされた説明: ExecutorService

値を返す実行用タスクを送信して、保留状態のタスク結果を表す Future を返します。Future の get メソッドは、正常に完了した時点でタスクの結果を返します。

タスクの待機をただちにブロックする場合は、result = exec.submit(aCallable).get(); の形式の構築を使用できます。

注:Executors クラスには、クロージャーに似たほかの一般オブジェクトを変換できるメソッドセットが含まれます。たとえば、PrivilegedAction を Callable 形式に変換して、送信可能にすることができます。

定義:

submit、インタフェース: ExecutorService

オーバーライド:

submit、クラス: AbstractExecutorService

パラメータ:

task - 送信するタスク

戻り値:

タスクの保留完了を表す Future

例外:

NullPointerException - タスクが null の場合

RejectedExecutionException - タスクの実行をスケジュールできない場合

submit

public <T> ForkJoinTask<T> submit(Runnable task,
                         T result)

インタフェースからコピーされた説明: ExecutorService

実行用の Runnable タスクを送信し、そのタスクを表す Future を返します。Future の get メソッドは、正常に完了した時点で指定された結果を返します。

定義:

submit、インタフェース: ExecutorService

オーバーライド:

submit、クラス: AbstractExecutorService

パラメータ:

task - 送信するタスク

result - 返す結果

戻り値:

タスクの保留完了を表す Future

例外:

NullPointerException - タスクが null の場合

RejectedExecutionException - タスクの実行をスケジュールできない場合

submit

public ForkJoinTask<?> submit(Runnable task)

インタフェースからコピーされた説明: ExecutorService

実行用の Runnable タスクを送信し、そのタスクを表す Future を返します。Future の get メソッドは、正常に完了した時点で null を返します。

定義:

submit、インタフェース: ExecutorService

オーバーライド:

submit、クラス: AbstractExecutorService

パラメータ:

task - 送信するタスク

戻り値:

タスクの保留完了を表す Future

例外:

NullPointerException - タスクが null の場合

RejectedExecutionException - タスクの実行をスケジュールできない場合

invokeAll

public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)

インタフェースからコピーされた説明: ExecutorService

指定されたタスクを実行し、すべて完了すると、ステータスと結果を含む Future のリストを返します。返されるリストの各要素に対して Future.isDone() は true になります。完了したタスクは、通常どおりか例外をスローすることで終了しています。オペレーションの進行中に、指定されたコレクションが変更された場合、このメソッドの結果は定義されていません。

定義:

invokeAll、インタフェース: ExecutorService

オーバーライド:

invokeAll、クラス: AbstractExecutorService

パラメータ:

tasks - タスクのコレクション

戻り値:

タスクを表す Future のリスト。リストの順序は、指定されたタスクリストのイテレータにより生成される順序と同じであり、各タスクは完了済みである。

例外:

NullPointerException - タスクまたはそのいずれかの要素が null の場合

RejectedExecutionException - いずれかのタスクの実行をスケジュールできない場合

getFactory

public ForkJoinPool.ForkJoinWorkerThreadFactory getFactory()

新規ワーカーの構築に使用されるファクトリを返します。

戻り値:

新しいワーカーの構築に使用されるファクトリ

getUncaughtExceptionHandler

public Thread.UncaughtExceptionHandler getUncaughtExceptionHandler()

タスクを実行中に発生した回復不能なエラーが原因で終了した内部ワーカースレッド用のハンドラを返します。

戻り値:

ハンドラ。ない場合は null

getParallelism

public int getParallelism()

このプールのターゲット並列性レベルを返します。

戻り値:

このプールのターゲット並列性レベル

getPoolSize

public int getPoolSize()

開始したがまだ終了していないワーカースレッド数を返します。このメソッドによって返された結果は、ほかのスレッドが協調してブロックされているときに並列性を維持するためにスレッドが作成された場合の getParallelism() とは異なる可能性があります。

戻り値:

ワーカースレッド数

getAsyncMode

public boolean getAsyncMode()

結合されないフォークされたタスクについて、このプールがローカルの先入れ先出しスケジュールモードを使用している場合、true を返します。

戻り値:

このプールが非同期モードを使用している場合は true

getRunningThreadCount

public int getRunningThreadCount()

タスクの結合またはその他の管理対象同期の待機をブロックしない、ワーカースレッドの推定数を返します。このメソッドは、実行中のスレッドの数を過大評価する可能性があります。

戻り値:

ワーカースレッド数

getActiveThreadCount

public int getActiveThreadCount()

現在タスクを横取りまたは実行しているスレッドの推定数を返します。このメソッドは、アクティブなスレッドの数を過大評価する可能性があります。

戻り値:

アクティブなスレッドの数

isQuiescent

public boolean isQuiescent()

すべてのワーカースレッドが現在アイドル状態の場合に true を返します。アイドルワーカーとは、ほかのスレッドから横取りできるタスクがなく、プールへの保留中の送信も存在しないために、実行するタスクを取得できないワーカーのことです。このメソッドは控えめです。すべてのスレッドがアイドルになってもすぐには true を返さない可能性がありますが、スレッドが非アクティブのままであれば、最終的には true になります。

戻り値:

すべてのスレッドが現在アイドル状態の場合は true

getStealCount

public long getStealCount()

1 つのスレッドのワークキューから別のスレッドによって横取りされたタスクの総数の推定値を返します。プールが静止していない場合、報告された値は、横取りの実際の総数を過小評価しています。この値は、分岐/結合プログラムの監視やチューニングに役立つことがあります。一般に、横取りの数はスレッドのビジー状態を維持できるだけの十分に大きな値であるべきですが、スレッド間のオーバーヘッドや競合を回避できるだけの十分に小さな値でもあるべきです。

戻り値:

横取りの数

getQueuedTaskCount

public long getQueuedTaskCount()

ワーカースレッドによって現在キューに保持されているタスクの総数の推定値を返します (プールに送信された、まだ開始されていないタスクは含まない)。この値は、プール内のすべてのスレッドにわたって反復することによって取得された近似値に過ぎません。このメソッドは、タスクの粒度のチューニングに役立つことがあります。

戻り値:

キューに入っているタスクの数

getQueuedSubmissionCount

public int getQueuedSubmissionCount()

このプールに送信された、まだ実行が開始されていないタスクの推定数を返します。このメソッドは、送信の数に比例して時間がかかることがあります。

戻り値:

キューに入っている送信の数

hasQueuedSubmissions

public boolean hasQueuedSubmissions()

このプールに送信された、まだ実行が開始されていないタスクがある場合は true を返します。

戻り値:

キューに入っている送信がない場合は true

pollSubmission

protected ForkJoinTask<?> pollSubmission()

まだ実行されていない次の送信が使用可能な場合、それを削除して復帰します。このメソッドは、複数のプールを含むシステムで作業を再割り当てする、このクラスへの拡張機能で役立つことがあります。

戻り値:

次の送信。ない場合は null

drainTasksTo

protected int drainTasksTo(Collection<? super ForkJoinTask<?>> c)

実行されなかった、送信およびフォークされた使用可能なすべてのタスクをスケジュールキューから削除し、実行ステータスを変更せずにそれらを指定されたコレクションに追加します。これらには、人為的に生成またはラップされたタスクが含まれる可能性があります。このメソッドは、プールが静止していることがわかっている場合にのみ呼び出されるように設計されています。その他のときに呼び出すと、すべてのタスクが削除されないことがあります。コレクション c に要素を追加しようとしているときに障害が検出されると、関連付けられた例外がスローされたときに、要素がどちらのコレクションにも存在しない場合と、どちらかまたは両方のコレクションに存在する場合があります。オペレーションの進行中に、指定されたコレクションが変更された場合の、このオペレーションの動作は定義されていません。

パラメータ:

c - 要素の転送先のコレクション

戻り値:

転送された要素の数

toString

public String toString()

実行状態、並列性レベル、およびワーカーおよびタスクカウントの指示を含めて、このプールおよびその状態を識別する文字列を返します。

オーバーライド:

toString、クラス: Object

戻り値:

このプールおよびその状態を識別する文字列

shutdown

public void shutdown()

順序正しくシャットダウンを開始します。以前に送信されたタスクが実行されますが、新規タスクは受け入れられません。シャットダウン後に呼び出しを実行しても、効果はありません。このメソッドの実行中に同時に送信されているタスクは拒否される場合と、されない場合があります。

例外:

SecurityException - セキュリティーマネージャーが存在し、呼び出し元が RuntimePermission("modifyThread") を持たないためスレッドを変更できない場合

shutdownNow

public List<Runnable> shutdownNow()

すべてのタスクの取り消しまたは停止を行い、あとで送信されたすべてのタスクを拒否することを試みます。このメソッドの実行中に同時に送信または実行されているタスクは拒否される場合と、されない場合があります。このメソッドは、タスクの依存関係が存在する場合に終了できるようにするために、既存のタスクと実行されなかったタスクの両方を取り消します。そのため、このメソッドは (ほかの一部の Executor の場合とは異なり) 常に空のリストを返します。

戻り値:

空のリスト

例外:

SecurityException - セキュリティーマネージャーが存在し、呼び出し元が RuntimePermission("modifyThread") を持たないためスレッドを変更できない場合

isTerminated

public boolean isTerminated()

シャットダウンに続いてすべてのタスクが完了していた場合、true を返します。

戻り値:

シャットダウンに続いてすべてのタスクが完了していた場合は true

isTerminating

public boolean isTerminating()

終了処理が開始されたがまだ完了していない場合、true を返します。このメソッドはデバッグに便利なことがあります。シャットダウンのあと十分に時間が経ってから報告された true の戻り値は、送信されたタスクが割り込みを無視または抑制したか、あるいは入出力を待機しているために、この executor が適切に終了されないことを示す可能性があります。タスクは通常、ブロック操作を必要としてはいけないことを記載している ForkJoinTask クラスの注意事項を参照してください。ただし、必要としている場合は、割り込みでそれを強制的に中止する必要があります。

戻り値:

終了中だが、まだ終了していない場合は true

isShutdown

public boolean isShutdown()

このプールがシャットダウンしていた場合、true を返します。

戻り値:

このプールがシャットダウンされている場合は true

awaitTermination

public boolean awaitTermination(long timeout,
                       TimeUnit unit)
                         throws InterruptedException

シャットダウン要求後にすべてのタスクが実行を完了していたか、タイムアウトが発生するか、現在のスレッドで割り込みが発生するか、そのいずれかが最初に発生するまでブロックします。

パラメータ:

timeout - 待機する最長時間

unit - timeout 引数の時間単位

戻り値:

この executor が終了した場合は true。終了前にタイムアウトが経過した場合は false

例外:

InterruptedException - 待機中に割り込みが発生した場合

managedBlock

public static void managedBlock(ForkJoinPool.ManagedBlocker blocker)
                         throws InterruptedException

指定されたブロッカに合わせてブロックします。現在のスレッドが ForkJoinWorkerThread である場合、このメソッドは、アクティブにされるスペアスレッドを必要に応じて調整して、現在のスレッドがブロックされている間の十分な並列性を確保する可能性があります。

呼び出し側が ForkJoinTask でない場合、このメソッドの動作は次と同等です。

 while (!blocker.isReleasable())
   if (blocker.block())
     return;
 

呼び出し側が ForkJoinTask である場合は、プールがまず並列性を確保するように拡張され、あとで調整される可能性があります。

パラメータ:

blocker - ブロッカ

例外:

InterruptedException - blocker.block がそれを実行した場合

newTaskFor

protected <T> RunnableFuture<T> newTaskFor(Runnable runnable,
                               T value)

次のクラスからコピーされた説明: AbstractExecutorService

指定された実行可能タスクおよびデフォルト値の RunnableFuture を返します。

オーバーライド:

newTaskFor、クラス: AbstractExecutorService

パラメータ:

runnable - ラップされる実行可能タスク

value - 返される Future のデフォルト値

戻り値:

実行時に基本となる実行可能タスクを実行し、Future として、指定された値をその結果として生成し、基本となるタスクの取り消しを提供する RunnableFuture。

newTaskFor

protected <T> RunnableFuture<T> newTaskFor(Callable<T> callable)

次のクラスからコピーされた説明: AbstractExecutorService

指定された呼び出し可能タスクの RunnableFuture を返します。

オーバーライド:

newTaskFor、クラス: AbstractExecutorService

パラメータ:

callable - ラップされる呼び出し可能タスク

戻り値:

実行時に基本となる呼び出し可能タスクを呼び出し、Future として、呼び出し可能タスクの結果をその結果として生成し、基本となるタスクの取り消しを提供する RunnableFuture。