Java并发ExecutorService接口

精华

小牛编辑

190浏览

2023-03-14

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)