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) 執行給定的任務，返回一個 Future 列表，其中包含所有任務完成後它們的狀態和結果。
3	<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) 執行給定的任務，返回一個 Future 列表，其中包含所有任務完成後它們的狀態和結果，或者超時到期，以先發生者為準。
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) 提交一個 Runnable 任務以執行，並返回一個 Future，表示該任務。
12	<T> Future<T> submit(Runnable task, T result) 提交一個 Runnable 任務以執行，並返回一個 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)

列印頁面