执行器服务接口

java.util.concurrent.ExecutorService 接口是 Executor 接口的子接口，并添加了管理各个任务和执行器本身生命周期的功能。

执行器服务方法

先生。	方法及说明
1	boolean waitTermination(长超时, TimeUnit 单位) 阻塞，直到所有任务在关闭请求后完成执行，或者发生超时，或者当前线程被中断，以先发生者为准。
2	<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> 任务) 执行给定的任务，在全部完成时返回保存其状态和结果的 Future 列表。
3	<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> 任务，长超时，TimeUnit 单位) 执行给定的任务，当所有任务完成或超时到期（以先发生者为准）时，返回保存其状态和结果的 Future 列表。
4	<T> T invokeAny(Collection<? 扩展 Callable<T>> 任务) 执行给定的任务，返回已成功完成的任务的结果（即，不引发异常）（如果有）。
5	<T> T invokeAny(Collection<? extends Callable<T>> 任务，长超时，TimeUnit 单位) 执行给定的任务，返回已成功完成的任务的结果（即，不引发异常）（如果在给定超时之前有任何执行）。
6	布尔 isShutdown() 如果此执行器已关闭，则返回 true。
7	布尔值已终止() 如果关闭后所有任务均已完成，则返回 true。
8	无效关闭() 启动有序关闭，其中执行先前提交的任务，但不会接受新任务。
9	列表<Runnable> shutdownNow() 尝试停止所有正在执行的任务，停止正在等待的任务的处理，并返回正在等待执行的任务的列表。
10	<T> Future<T> 提交（Callable<T> 任务）提交一个返回值的任务来执行，并返回一个表示任务待处理结果的 Future。
11	Future<?> 提交（可运行任务）提交一个 Runnable 任务来执行并返回一个表示该任务的 Future。
12	<T> Future<T> 提交（可运行任务，T 结果）提交一个 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)