Java併發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)

提交值返回任務以執行，並返回代表任務待處理結果。

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)