Интерфейс ExecutorService

public interface ExecutorService
extends Executor

A Executor который предоставляет методы для управления завершением и методы, которые могут создать Future для отслеживания прогресса одной или нескольких асинхронных задач.

Объект ExecutorService может быть остановлен, что заставит его отклонять новые задачи. Для остановки объекта ExecutorService предоставляются два различных метода. Метод shutdown() позволит ранее отправленным задачам завершиться, прежде чем он будет остановлен, в то время как метод shutdownNow() предотвращает запуск ожидающих задач и пытается остановить текущие выполняющиеся задачи. После завершения исполнителя нет задач, активно выполняющихся, ожидающих выполнения или новых задач, которые можно отправить. Неиспользуемый ExecutorService следует остановить, чтобы освободить ресурсы.

Метод submit расширяет базовый метод Executor.execute(Runnable), создавая и возвращая Future, который можно использовать для отмены выполнения и/или ожидания завершения. Методы invokeAny и invokeAll выполняют наиболее часто используемые формы массового выполнения, выполняя коллекцию задач, а затем ожидая завершения как минимум одной или всех из них. (Класс ExecutorCompletionService можно использовать для написания настраиваемых вариантов этих методов.)

Класс Executors предоставляет фабричные методы для служб исполнителей, предоставляемых в этом пакете.

Примеры использования

Вот пример сетевой службы, в которой потоки в пуле потоков обрабатывают входящие запросы. Она использует предварительно настроенный метод фабрики Executors.newFixedThreadPool(int):

class NetworkService implements Runnable {
   private final ServerSocket serverSocket;
   private final ExecutorService pool;

   public NetworkService(int port, int poolSize)
       throws IOException {
     serverSocket = new ServerSocket(port);
     pool = Executors.newFixedThreadPool(poolSize);
   }

   public void run() { // run the service
     try {
       for (;;) {
         pool.execute(new Handler(serverSocket.accept()));
       }
     } catch (IOException ex) {
       pool.shutdown();
     }
   }
 }

 class Handler implements Runnable {
   private final Socket socket;
   Handler(Socket socket) { this.socket = socket; }
   public void run() {
     // read and service request on socket
   }
 }

Следующий метод останавливает ExecutorService в двух фазах, сначала вызывая shutdown для отклонения входящих задач, а затем вызывая shutdownNow, если необходимо, для отмены любых задач, которые остались в очереди:

void shutdownAndAwaitTermination(ExecutorService pool) {
   pool.shutdown(); // Disable new tasks from being submitted
   try {
     // Wait a while for existing tasks to terminate
     if (!pool.awaitTermination(60, TimeUnit.SECONDS)) {
       pool.shutdownNow(); // Cancel currently executing tasks
       // Wait a while for tasks to respond to being cancelled
       if (!pool.awaitTermination(60, TimeUnit.SECONDS))
           System.err.println("Pool did not terminate");
     }
   } catch (InterruptedException ie) {
     // (Re-)Cancel if current thread also interrupted
     pool.shutdownNow();
     // Preserve interrupt status
     Thread.currentThread().interrupt();
   }
 }

Эффекты согласованности памяти: Действия в потоке до отправки задачи Runnable или Callable исполнителю ExecutorService предшествуют любым действиям, выполняемым этой задачей, которые, в свою очередь, предшествуют получению результата через Future.get().