Интерфейс ExecutorService

public interface ExecutorService extends Executor, AutoCloseable

Объект 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 также может быть создан и закрыт (остановлен, блокируясь до завершения) следующим образом; иллюстрируя с помощью другого фабричного метода Executors:

 
 try (ExecutorService e =  Executors.newWorkStealingPool()) {
   // submit or execute many tasks with e ...
 }

Дополнительная настройка также возможна. Например, следующий метод останавливает объект 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().