Интерфейс ExecutorService

public interface ExecutorService extends Executor

Управляемый 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 ex) {
     // (Re-)Cancel if current thread also interrupted
     pool.shutdownNow();
     // Preserve interrupt status
     Thread.currentThread().interrupt();
   }
 }

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