クラスjava.util.concurrent.ForkJoinTask
の使用
ForkJoinTaskを使用するパッケージ
-
java.util.concurrentでのForkJoinTaskの使用
修飾子と型クラス説明classトリガーされた時点で保留中のアクションが残っていない場合に実行される完了アクションを含むForkJoinTaskです。class結果の出ない再帰的なForkJoinTask。class結果を生成する再帰的なForkJoinTask。型ForkJoinTaskの型パラメータを持つjava.util.concurrentのメソッド修飾子と型メソッド説明static <T extends ForkJoinTask<?>>
Collection<T> ForkJoinTask.invokeAll(Collection<T> tasks) 指定されたコレクション内のすべてのタスクをフォークし、各タスクに対してisDoneが適用されるか、(チェックされない)例外が発生する場合に復帰します。後者の場合、例外が再スローされます。ForkJoinTaskを返すjava.util.concurrentのメソッド修飾子と型メソッド説明static ForkJoinTask<?> 指定されたRunnableのrunメソッドをアクションとして実行する新しいForkJoinTaskを返し、join()実行時にnullの結果を返します。static <T> ForkJoinTask<T> 指定されたRunnableのrunメソッドをアクションとして実行する新しいForkJoinTaskを返し、join()実行時に指定された結果を返します。static <T> ForkJoinTask<T> 指定されたCallableのcallメソッドをアクションとして実行する新しいForkJoinTaskを返し、その結果をjoin()実行時に返し、発生したチェック例外をRuntimeExceptionに変換します。static ForkJoinTask<?> ForkJoinTask.adaptInterruptible(Runnable runnable) 指定されたRunnableのrunメソッドをアクションとして実行する新しいForkJoinTaskを返し、join()でnullを返し、検出されたチェック例外をRuntimeExceptionに変換します。static <T> ForkJoinTask<T> ForkJoinTask.adaptInterruptible(Runnable runnable, T result) 指定されたRunnableのrunメソッドをアクションとして実行する新しいForkJoinTaskを返し、join()で指定した結果を返し、検出されたチェック例外をRuntimeExceptionに変換します。static <T> ForkJoinTask<T> ForkJoinTask.adaptInterruptible(Callable<? extends T> callable) 指定されたCallableのcallメソッドをアクションとして実行する新しいForkJoinTaskを返し、その結果をjoin()実行時に返し、発生したチェック例外をRuntimeExceptionに変換します。<T> ForkJoinTask<T> ForkJoinPool.externalSubmit(ForkJoinTask<T> task) ForkJoinTask以外のクライアントから発行されたかのように、指定されたタスクを送信します。final ForkJoinTask<V> ForkJoinTask.fork()現在のタスクが実行されているプール内でこのタスクを非同期で実行するように調整します(該当する場合)。inForkJoinPool()でない場合は、ForkJoinPool.commonPool()を使用します。<T> ForkJoinTask<T> ForkJoinPool.lazySubmit(ForkJoinTask<T> task) 使用可能なアクティブ・スレッドがない状態で最終的に実行されることを保証せずに、指定されたタスクを送信します。protected static ForkJoinTask<?> ForkJoinTask.peekNextLocalTask()現在のスレッドによってキューに入れられたがまだ実行されていないタスクがすぐに使用できる場合、そのタスクを返し、スケジュール解除や実行は行いません。protected static ForkJoinTask<?> ForkJoinTask.pollNextLocalTask()現在のスレッドがForkJoinPoolで動作している場合に、現在のスレッドによってキューに入れられたがまだ実行されていない次のタスクを、実行せずにスケジュール解除して復帰します。protected ForkJoinTask<?> ForkJoinPool.pollSubmission()まだ実行されていない次の送信が使用可能な場合、それを削除して復帰します。protected static ForkJoinTask<?> ForkJoinTask.pollSubmission()現在のスレッドがForkJoinPoolで動作している場合、スケジュールを解除し、実行せずに、プールに外部に送信されたタスク(使用可能な場合)を返します。protected static ForkJoinTask<?> ForkJoinTask.pollTask()現在のスレッドがForkJoinPoolで動作しており、現在のスレッドによってキューに入れられたがまだ実行されていない次のタスクが使用可能な場合、そのタスクを実行せずにスケジュール解除して復帰します。そのようなタスクが使用可能でない場合は、他のスレッドによってフォークされたタスクが対象になります(使用可能な場合)。ForkJoinTask<?> <T> ForkJoinTask<T> <T> ForkJoinTask<T> <T> ForkJoinTask<T> ForkJoinPool.submit(ForkJoinTask<T> task) 実行用のForkJoinTaskを送信します。型ForkJoinTaskのパラメータを持つjava.util.concurrentのメソッド修飾子と型メソッド説明voidForkJoinPool.execute(ForkJoinTask<?> task) 指定されたタスクの(非同期)実行を調整します。<T> ForkJoinTask<T> ForkJoinPool.externalSubmit(ForkJoinTask<T> task) ForkJoinTask以外のクライアントから発行されたかのように、指定されたタスクを送信します。<T> TForkJoinPool.invoke(ForkJoinTask<T> task) 指定されたタスクを実行し、完了時にその結果を返します。static voidForkJoinTask.invokeAll(ForkJoinTask<?>... tasks) 指定されたタスクをフォークし、各タスクに対してisDoneが適用されるか、(チェックされない)例外が発生する場合に復帰します。後者の場合、例外が再スローされます。static voidForkJoinTask.invokeAll(ForkJoinTask<?> t1, ForkJoinTask<?> t2) 指定されたタスクをフォークし、各タスクに対してisDoneが適用されるか、(チェックされない)例外が発生する場合に復帰します。後者の場合、例外が再スローされます。<T> ForkJoinTask<T> ForkJoinPool.lazySubmit(ForkJoinTask<T> task) 使用可能なアクティブ・スレッドがない状態で最終的に実行されることを保証せずに、指定されたタスクを送信します。<T> ForkJoinTask<T> ForkJoinPool.submit(ForkJoinTask<T> task) 実行用のForkJoinTaskを送信します。型ForkJoinTaskの型引数を持つjava.util.concurrentのメソッド・パラメータ修飾子と型メソッド説明protected intForkJoinPool.drainTasksTo(Collection<? super ForkJoinTask<?>> c) 実行されなかった、送信およびフォークされた使用可能なすべてのタスクをスケジュール・キューから削除し、実行ステータスを変更せずにそれらを指定されたコレクションに追加します。