public interface ExecutorService extends Executor
Future を生成できるメソッドを提供する Executor です。
ExecutorService はシャットダウンすることができ、それにより、新しいタスクを拒否するようになります。ExecutorService をシャットダウンするための 2 つの異なるメソッドが提供されています。shutdown() メソッドは以前に送信したタスクを終了前に実行することができ、shutdownNow() メソッドは待機中のタスクが開始されないようにし、現在実行中のタスクを停止しようとします。終了時、executor には、実行中のアクティブなタスクや実行を待機中のタスクは存在せず、新規タスクを送信することもできません。未使用の ExecutorService は、そのリソースの再利用を可能にするために、シャットダウンするようにしてください。
submit メソッドは、実行の取り消しや完了の待機に使用できる Future を作成して返すことによって、基底メソッド Executor.execute(java.lang.Runnable) を拡張します。invokeAny メソッドと invokeAll メソッドは、タスクのコレクションを実行してから、少なくとも 1 つまたはすべてのタスクの完了を待機することによって、もっとも一般的に役立つ形式の一括実行を行います。(ExecutorCompletionService クラスを使用すると、これらのメソッドのカスタマイズされたバリアントを記述できます。)
Executors クラスは、このパッケージで提供される executor サービスのためのファクトリメソッドを提供します。
Executors.newFixedThreadPool(int) ファクトリメソッドを使用します。
class NetworkService implements Runnable {
private final ServerSocket serverSocket;
private final ExecutorService pool;
public NetworkService(int port, int poolSize)
throws IOException {
serverSocket = new ServerSocket(port);
pool = Executors.newFixedThreadPool(poolSize);
}
public void run() { // run the service
try {
for (;;) {
pool.execute(new Handler(serverSocket.accept()));
}
} catch (IOException ex) {
pool.shutdown();
}
}
}
class Handler implements Runnable {
private final Socket socket;
Handler(Socket socket) { this.socket = socket; }
public void run() {
// read and service request on socket
}
}
次のメソッドは、ExecutorService を 2 段階でシャットダウンします。最初に shutdown を呼び出して着信タスクを拒否し、次に必要に応じて shutdownNow を呼び出して中途のタスクをすべて取り消します。
void shutdownAndAwaitTermination(ExecutorService pool) {
pool.shutdown(); // Disable new tasks from being submitted
try {
// Wait a while for existing tasks to terminate
if (!pool.awaitTermination(60, TimeUnit.SECONDS)) {
pool.shutdownNow(); // Cancel currently executing tasks
// Wait a while for tasks to respond to being cancelled
if (!pool.awaitTermination(60, TimeUnit.SECONDS))
System.err.println("Pool did not terminate");
}
} catch (InterruptedException ie) {
// (Re-)Cancel if current thread also interrupted
pool.shutdownNow();
// Preserve interrupt status
Thread.currentThread().interrupt();
}
}
メモリー整合性効果: Runnable または Callable タスクを ExecutorService に送信する前のスレッド内のアクションは、そのタスクによって実行されるすべてのアクションの前に発生し、それらがさらに、Future.get() によって結果が取得される前に発生します。
| 修飾子と型 | メソッドと説明 |
|---|---|
boolean |
awaitTermination(long timeout, TimeUnit unit)
シャットダウン要求後にすべてのタスクが実行を完了していたか、タイムアウトが発生するか、現在のスレッドで割り込みが発生するか、そのいずれかが最初に発生するまでブロックします。
|
<T> List<Future<T>> |
invokeAll(Collection<? extends Callable<T>> tasks)
指定されたタスクを実行し、すべて完了すると、ステータスと結果を含む Future のリストを返します。
|
<T> List<Future<T>> |
invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
指定されたタスクを実行し、すべてが完了するか時間切れになるか、そのいずれかが最初に発生した時点で、ステータスと結果を含む Future のリストを返します。
|
<T> T |
invokeAny(Collection<? extends Callable<T>> tasks)
指定されたタスクを実行し、例外をスローせずに正常に完了したタスクが存在する場合は、その結果を返します。
|
<T> T |
invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
指定されたタスクを実行し、タイムアウトが経過する前に例外をスローせずに正常に完了したタスクが存在する場合は、その結果を返します。
|
boolean |
isShutdown()
この executor がシャットダウンしていた場合、true を返します。
|
boolean |
isTerminated()
シャットダウンに続いてすべてのタスクが完了していた場合、true を返します。
|
void |
shutdown()
順序正しくシャットダウンを開始します。以前に送信されたタスクが実行されますが、新規タスクは受け入れられません。
|
List<Runnable> |
shutdownNow()
実行中のアクティブなタスクすべての停止を試み、待機中のタスクの処理を停止し、実行を待機していたタスクのリストを返します。
|
<T> Future<T> |
submit(Callable<T> task)
値を返す実行用タスクを送信して、保留状態のタスク結果を表す Future を返します。
|
Future<?> |
submit(Runnable task)
実行用の Runnable タスクを送信し、そのタスクを表す Future を返します。
|
<T> Future<T> |
submit(Runnable task, T result)
実行用の Runnable タスクを送信し、そのタスクを表す Future を返します。
|
void shutdown()
このメソッドは、以前に送信されたタスクが実行を完了するのを待機しません。これを実行するには、awaitTermination を使ってください。
SecurityException - セキュリティーマネージャーが存在する状況でこの ExecutorService のシャットダウンを実行すると、呼び出し側には変更を許可しないスレッドを操作できる場合。これは、RuntimePermission("modifyThread") を保持しないか、セキュリティーマネージャーの checkAccess メソッドがアクセスを拒否するためである。List<Runnable> shutdownNow()
このメソッドは、アクティブに実行中のタスクが終了するのを待機しません。これを実行するには、awaitTermination を使ってください。
実行中のアクティブなタスク処理を停止するために最善の努力をすること以上の保証はありません。たとえば、標準的な実装では Thread.interrupt() を使用して取り消すため、割り込みに応答できなかったタスクがすべて終了しなくなる可能性があります。
SecurityException - セキュリティーマネージャーが存在する状況でこの ExecutorService のシャットダウンを実行すると、呼び出し側には変更を許可しないスレッドを操作できる場合。これは、RuntimePermission("modifyThread") を保持しないか、セキュリティーマネージャーの checkAccess メソッドがアクセスを拒否するためである。boolean isShutdown()
boolean isTerminated()
boolean awaitTermination(long timeout,
TimeUnit unit)
throws InterruptedException
timeout - 待機する最長時間unit - timeout 引数の時間単位InterruptedException - 待機中に割り込みが発生した場合<T> Future<T> submit(Callable<T> task)
タスクの待機をただちにブロックする場合は、result = exec.submit(aCallable).get(); の形式の構築を使用できます。
注:Executors クラスには、クロージャーに似たほかの一般オブジェクトを変換できるメソッドセットが含まれます。たとえば、PrivilegedAction を Callable 形式に変換して、送信可能にすることができます。
task - 送信するタスクRejectedExecutionException - タスクの実行をスケジュールできない場合NullPointerException - タスクが null の場合<T> Future<T> submit(Runnable task, T result)
task - 送信するタスクresult - 返す結果RejectedExecutionException - タスクの実行をスケジュールできない場合NullPointerException - タスクが null の場合Future<?> submit(Runnable task)
task - 送信するタスクRejectedExecutionException - タスクの実行をスケジュールできない場合NullPointerException - タスクが null の場合<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException
Future.isDone() は true になります。完了したタスクは、通常どおりか例外をスローすることで終了しています。オペレーションの進行中に、指定されたコレクションが変更された場合、このメソッドの結果は定義されていません。tasks - タスクのコレクションInterruptedException - 待機中に割り込みが発生した場合。この場合、未完了のタスクは取り消される。NullPointerException - タスクまたはそのいずれかの要素が null の場合RejectedExecutionException - いずれかのタスクの実行をスケジュールできない場合<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException
Future.isDone() は true になります。返された時点で、完了していないタスクは取り消されます。完了したタスクは、通常どおりか例外をスローすることで終了しています。オペレーションの進行中に、指定されたコレクションが変更された場合、このメソッドの結果は定義されていません。tasks - タスクのコレクションtimeout - 待機する最長時間unit - timeout 引数の時間単位InterruptedException - 待機中に割り込みが発生した場合。この場合、未完了のタスクは取り消されるNullPointerException - タスク、その要素のいずれか、または単位が null の場合RejectedExecutionException - いずれかのタスクの実行をスケジュールできない場合<T> T invokeAny(Collection<? extends Callable<T>> tasks) throws InterruptedException, ExecutionException
tasks - タスクのコレクションInterruptedException - 待機中に割り込みが発生した場合NullPointerException - タスクまたは実行に従ういずれかの要素タスクが null の場合IllegalArgumentException - タスクが空の場合ExecutionException - 正常に完了したタスクがない場合RejectedExecutionException - タスクの実行をスケジュールできない場合<T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException
tasks - タスクのコレクションtimeout - 待機する最長時間unit - timeout 引数の時間単位InterruptedException - 待機中に割り込みが発生した場合NullPointerException - タスク、単位、または実行に従ういずれかの要素タスクが null の場合TimeoutException - タスクが正常に完了する前に、指定されたタイムアウトが経過した場合ExecutionException - 正常に完了したタスクがない場合RejectedExecutionException - タスクの実行をスケジュールできない場合 バグまたは機能を送信
詳細な API リファレンスおよび開発者ドキュメントについては、Java SE のドキュメントを参照してください。そのドキュメントには、概念的な概要、用語の定義、回避方法、有効なコード例などの、開発者を対象にしたより詳細な説明が含まれています。
Copyright © 1993, 2013, Oracle and/or its affiliates. All rights reserved.