Java并发执行程序服务接口


一个java.util.concurrent.ExecutorService接口是Executor接口的子接口,并增加了管理生命周期的功能,包括单个任务和执行程序本身。

ExecutorService方法

Sr.No. 方法和描述
1 boolean awaitTermination(long timeout, TimeUnit unit) 阻塞,直到所有任务在关闭请求之后所有任务都已完成执行,或发生超时,或当前线程中断,以先发生者为准。
2 List> invokeAll(Collection> tasks) 执行给定的任务,返回一份持有其状态和结果的期货清单,当全部完成时。
3 List> invokeAll(Collection> tasks, long timeout, TimeUnit unit) 执行给定的任务,当所有完成或超时到期时返回一份持有其状态和结果的期货清单,以先发生者为准。
4 T invokeAny(Collection> tasks) 执行给定的任务,返回已成功完成的任务(即,没有抛出异常)的结果,如果有的话。
5 T invokeAny(Collection> tasks, long timeout, TimeUnit unit) 执行给定的任务,返回已成功完成的任务(即,没有抛出异常)的结果,如果在给定超时过去之前执行了任务。
6 boolean isShutdown() 如果此执行程序已关闭,则返回true。
7 boolean isTerminated() 如果所有任务在关闭后都完成,则返回true。
8 void shutdown() 启动先前提交的任务执行的有序关闭,但不会接受新任务。
9 List shutdownNow() 尝试停止所有正在执行的任务,暂停等待任务的处理,并返回正在等待执行的任务列表。
10 Future submit(Callable task) 提交执行的返回值任务,并返回表示未完成任务结果的Future。
11 Future submit(Runnable task) 提交可执行的任务并返回表示该任务的Future。
12 Future 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)