ExecutorServiceインターフェース

java.util.concurrent.ExecutorServiceインターフェースは、Executorインターフェースのサブインターフェースであり、個々のタスクとエグゼキューター自体の両方のライフサイクルを管理する機能を追加します。

ExecutorServiceメソッド

シニア番号	方法と説明
1	boolean awaitTermination(long timeout, TimeUnit unit) シャットダウン要求後にすべてのタスクの実行が完了するか、タイムアウトが発生するか、現在のスレッドが中断されるまで、どちらか早い方でブロックします。
2	<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) 指定されたタスクを実行し、すべてが完了すると、ステータスと結果を保持する先物のリストを返します。
3	<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) 指定されたタスクを実行し、すべてが完了したとき、またはタイムアウトが期限切れになったときのいずれか早い方で、ステータスと結果を保持する先物のリストを返します。
4	<T> T invokeAny(Collection<? extends Callable<T>> tasks) 指定されたタスクを実行し、正常に完了したタスクの結果を返します（つまり、例外をスローしません）。
5	<T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) 指定されたタスクを実行し、正常に完了したタスクの結果を返します（つまり、例外をスローせずに）。指定されたタイムアウトが経過する前に実行した場合は、その結果を返します。
6	boolean isShutdown() このエグゼキュータがシャットダウンされている場合はtrueを返します。
7	boolean isTerminated() シャットダウン後にすべてのタスクが完了した場合はtrueを返します。
8	void shutdown() 以前に送信されたタスクが実行される正常なシャットダウンを開始しますが、新しいタスクは受け入れられません。
9	List<Runnable> shutdownNow() アクティブに実行されているすべてのタスクの停止を試み、待機中のタスクの処理を停止し、実行を待機していたタスクのリストを返します。
10	<T> Future<T> submit(Callable<T> task) 実行のために値を返すタスクを送信し、タスクの保留中の結果を表すFutureを返します。
11	Future<?> submit(Runnable task) 実行可能なタスクを実行のために送信し、そのタスクを表すFutureを返します。
12	<T> Future<T> submit(Runnable task, T result) 実行可能なタスクを実行のために送信し、そのタスクを表すFutureを返します。

例

次のTestThreadプログラムは、スレッドベースの環境でのExecutorServiceインターフェイスの使用法を示しています。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class TestThread {

   public static void main(final String[] arguments) throws InterruptedException {
      ExecutorService executor = Executors.newSingleThreadExecutor();

      try {
         executor.submit(new Task());
         System.out.println("Shutdown executor");
         executor.shutdown();
         executor.awaitTermination(5, TimeUnit.SECONDS);
      } catch (InterruptedException e) {
         System.err.println("tasks interrupted");
      } finally {

         if (!executor.isTerminated()) {
            System.err.println("cancel non-finished tasks");
         }
         executor.shutdownNow();
         System.out.println("shutdown finished");
      }
   }

   static class Task implements Runnable {
      
      public void run() {
         
         try {
            Long duration = (long) (Math.random() * 20);
            System.out.println("Running Task!");
            TimeUnit.SECONDS.sleep(duration);
         } catch (InterruptedException e) {
            e.printStackTrace();
         }
      }
   }	   
}

これにより、次の結果が得られます。

出力

Shutdown executor
Running Task!
shutdown finished
cancel non-finished tasks
java.lang.InterruptedException: sleep interrupted
	at java.lang.Thread.sleep(Native Method)
	at java.lang.Thread.sleep(Thread.java:302)
	at java.util.concurrent.TimeUnit.sleep(TimeUnit.java:328)
	at TestThread$Task.run(TestThread.java:39)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)