ExecutorService (Платформа Java SE 7)

Все Суперинтерфейсы:

Исполнитель

Все Известные Подынтерфейсы:

ScheduledExecutorService

Все Известные Классы с реализацией:

AbstractExecutorService, ForkJoinPool, ScheduledThreadPoolExecutor, ThreadPoolExecutor
```
public interface ExecutorService
extends Executor
```
Executor это обеспечивает методы, чтобы управлять завершением и методами, которые могут произвести a Future для того, чтобы отследить продвижение одной или более асинхронных задач.
ExecutorService может быть выключен, который заставит его отклонять новые задачи. Два различных метода обеспечиваются для того, чтобы они завершили работу ExecutorService. shutdown() метод позволит ранее представленным задачам выполниться перед завершением, в то время как shutdownNow() метод препятствует тому, чтобы ожидающие задачи запустились, и пытается прекратить в настоящий момент выполнять задачи. После завершения у исполнителя нет никаких задач, активно выполняющихся, никакие задачи, ждущие выполнения, и никакие новые задачи не могут быть представлены. Неиспользованный ExecutorService должен быть выключен, чтобы позволить восстановление его ресурсов.
Метод submit расширяет основной метод Executor.execute(java.lang.Runnable) создавая и возвращаясь a 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();
   }
 }
 
```
Эффекты непротиворечивости памяти: Действия в потоке до представления a Runnable или Callable задача к ExecutorService произойдите - перед любыми мерами, предпринятыми той задачей, которые поочередно происходят - прежде, чем результат будет получен через Future.get().
С тех пор:

1.5

Сводка метода

Методы
Модификатор и Тип	Метод и Описание
`boolean`	`awaitTermination(long timeout, TimeUnit unit)` Блоки до всех задач завершили выполнение после запроса завершения работы, или тайм-аут происходит, или текущий поток прерывается, какой бы ни происходит сначала.
`<T> List<Future<T>>`	`invokeAll(Collection<? extends Callable<T>> tasks)` Выполняет данные задачи, возвращая список Фьючерса, содержащего их состояние, и заканчивается, когда все завершаются.
`<T> List<Future<T>>`	`invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)` Выполняет данные задачи, возвращая список Фьючерса, содержащего их состояние, и заканчивается, когда все завершаются, или тайм-аут истекает, какой бы ни происходит сначала.
`<T> T`	`invokeAny(Collection<? extends Callable<T>> tasks)` Выполняет данные задачи, возвращая результат того, который завершился успешно (то есть, не выдавая исключение), если кто-либо делает.
`<T> T`	`invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)` Выполняет данные задачи, возвращая результат того, который завершился успешно (то есть, не выдавая исключение), если кто-либо делает прежде, чем данный тайм-аут протекает.
`boolean`	`isShutdown()` `true` возвратов, если этот исполнитель был выключен.
`boolean`	`isTerminated()` `true` возвратов, если все задачи завершились следующий выключенный.
`void`	`shutdown()` Инициирует аккуратное завершение работы, на котором выполняются ранее представленные задачи, но никакие новые задачи не будут приняты.
`List<Runnable>`	`shutdownNow()` Попытки остановить все активно выполняющиеся задачи, останавливает обработку ожидающих задач, и возвращает список задач, которые ждали выполнения.
`<T> Future<T>`	`submit(Callable<T> task)` Представляет возвращающую значение задачу для выполнения и возвращает Будущее, представляющее результаты на ожидании задачи.
`Future<?>`	`submit(Runnable task)` Представляет Выполнимую задачу для выполнения и возвращает Будущее, представляющее ту задачу.
`<T> Future<T>`	`submit(Runnable task, T result)` Представляет Выполнимую задачу для выполнения и возвращает Будущее, представляющее ту задачу.

Методы, наследованные от интерфейса java.util.concurrent. Исполнитель
выполниться

- Деталь метода
  - завершение работы
```
void shutdown()
```
    Инициирует аккуратное завершение работы, на котором выполняются ранее представленные задачи, но никакие новые задачи не будут приняты. Вызов не имеет никакого дополнительного эффекта если уже выключенный.
    Этот метод не ожидает ранее представленных задач завершить выполнение. Использовать awaitTermination сделать это.
    
    Броски:
    
    SecurityException - если менеджер безопасности существует, и завершающий работу этого ExecutorService может управлять потоками, которые вызывающей стороне не разрешают изменить, потому что это не содержит RuntimePermission("modifyThread"), или метод checkAccess менеджера безопасности лишает доступа.
  - shutdownNow
```
List<Runnable> shutdownNow()
```
    Попытки остановить все активно выполняющиеся задачи, останавливает обработку ожидающих задач, и возвращает список задач, которые ждали выполнения.
    Этот метод не ожидает активного выполнения задач завершиться. Использовать awaitTermination сделать это.
    Нет никаких гарантий вне попыток максимальных усилий прекратить обрабатывать активно выполняющиеся задачи. Например, типичные реализации отменят через Thread.interrupt(), таким образом, любая задача, которая не в состоянии ответить на прерывания, никогда, возможно, не завершается.
    
    Возвраты:
    список задач это никогда не начинало выполнение
    
    Броски:
    
    SecurityException - если менеджер безопасности существует, и завершающий работу этого ExecutorService может управлять потоками, которые вызывающей стороне не разрешают изменить, потому что это не содержит RuntimePermission("modifyThread"), или метод checkAccess менеджера безопасности лишает доступа.
  - isShutdown
```
boolean isShutdown()
```
    true возвратов, если этот исполнитель был выключен.
    
    Возвраты:
    true, если этот исполнитель был выключен
  - isTerminated
```
boolean isTerminated()
```
    true возвратов, если все задачи завершились следующий выключенный. Отметьте, что isTerminated никогда не является true, если или shutdown или shutdownNow не вызвали сначала.
    
    Возвраты:
    true, если все задачи завершились следующий выключенный
  - awaitTermination
```
boolean awaitTermination(long timeout,
                       TimeUnit unit)
                         throws InterruptedException
```
    Блоки до всех задач завершили выполнение после запроса завершения работы, или тайм-аут происходит, или текущий поток прерывается, какой бы ни происходит сначала.
    
    Параметры:
    timeout - максимальное время, чтобы ожидать
    unit - единица измерения времени параметра тайм-аута
    
    Возвраты:
    true, если этот исполнитель завершал и false если тайм-аут, законченный перед завершением
    
    Броски:
    
    InterruptedException - если прервано, ожидая
  - подчиниться
```
<T> Future<T> submit(Callable<T> task)
```
    Представляет возвращающую значение задачу для выполнения и возвращает Будущее, представляющее результаты на ожидании задачи. Метод get Будущего возвратит результат задачи после успешного завершения.
    Если требуется сразу блокировать ожидание задачи, можно использовать конструкции формы result = exec.submit(aCallable).get();
    Отметьте: Executors класс включает ряд методов, которые могут преобразовать некоторые другие общие подобные закрытию объекты, например, PrivilegedAction к Callable сформируйтесь, таким образом, они могут быть представлены.
    
    Параметры:
    task - задача подчиниться
    
    Возвраты:
    Будущее представление завершение на ожидании задачи
    
    Броски:
    
    RejectedExecutionException - если задача не может быть запланирована для выполнения
    
    NullPointerException - если задачей является нуль
  - подчиниться
```
<T> Future<T> submit(Runnable task,
                   T result)
```
    Представляет Выполнимую задачу для выполнения и возвращает Будущее, представляющее ту задачу. Метод get Будущего возвратит данный результат после успешного завершения.
    
    Параметры:
    task - задача подчиниться
    result - результат возвратиться
    
    Возвраты:
    Будущее представление завершение на ожидании задачи
    
    Броски:
    
    RejectedExecutionException - если задача не может быть запланирована для выполнения
    
    NullPointerException - если задачей является нуль
  - подчиниться
```
Future<?> submit(Runnable task)
```
    Представляет Выполнимую задачу для выполнения и возвращает Будущее, представляющее ту задачу. Метод get Будущего возвратит null после успешного завершения.
    
    Параметры:
    task - задача подчиниться
    
    Возвраты:
    Будущее представление завершение на ожидании задачи
    
    Броски:
    
    RejectedExecutionException - если задача не может быть запланирована для выполнения
    
    NullPointerException - если задачей является нуль
  - invokeAll
```
<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
                          throws InterruptedException
```
    Выполняет данные задачи, возвращая список Фьючерса, содержащего их состояние, и заканчивается, когда все завершаются. Future.isDone() true для каждого элемента возвращенного списка. Отметьте, что завершенная задача, возможно, завершилась или обычно или выдавая исключение. Результаты этого метода неопределены, если данный набор изменяется, в то время как эта работа происходит.
    
    Параметры:
    tasks - набор задач
    
    Возвраты:
    Список Фьючерса, представляющего задачи, в том же самом последовательном порядке как произведено iterator для данного списка задач, каждый из которых завершился.
    
    Броски:
    
    InterruptedException - если прервано, ожидая, когда отменяются незаконченные задачи.
    
    NullPointerException - если задачами или каким-либо из его элементов является null
    
    RejectedExecutionException - если какая-либо задача не может быть запланирована для выполнения
  - invokeAll
```
<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
                            long timeout,
                            TimeUnit unit)
                          throws InterruptedException
```
    Выполняет данные задачи, возвращая список Фьючерса, содержащего их состояние, и заканчивается, когда все завершаются, или тайм-аут истекает, какой бы ни происходит сначала. Future.isDone() true для каждого элемента возвращенного списка. По возврату отменяются задачи, которые не завершились. Отметьте, что завершенная задача, возможно, завершилась или обычно или выдавая исключение. Результаты этого метода неопределены, если данный набор изменяется, в то время как эта работа происходит.
    
    Параметры:
    tasks - набор задач
    timeout - максимальное время, чтобы ожидать
    unit - единица измерения времени параметра тайм-аута
    
    Возвраты:
    список Фьючерса, представляющего задачи, в том же самом последовательном порядке как произведено iterator для данного списка задач. Если работа убирала не время, каждая задача завершится. Если это отбывало срок, некоторые из этих задач не будут завершаться.
    
    Броски:
    
    InterruptedException - если прервано, ожидая, когда отменяются незаконченные задачи
    
    NullPointerException - если задачами, каким-либо из его элементов, или модулем является null
    
    RejectedExecutionException - если какая-либо задача не может быть запланирована для выполнения
  - invokeAny
```
<T> T invokeAny(Collection<? extends Callable<T>> tasks)
            throws InterruptedException,
                   ExecutionException
```
    Выполняет данные задачи, возвращая результат того, который завершился успешно (то есть, не выдавая исключение), если кто-либо делает. По нормальному или исключительному возврату отменяются задачи, которые не завершились. Результаты этого метода неопределены, если данный набор изменяется, в то время как эта работа происходит.
    
    Параметры:
    tasks - набор задач
    
    Возвраты:
    результат возвратился одной из задач
    
    Броски:
    
    InterruptedException - если прервано, ожидая
    
    NullPointerException - если задачами или какой-либо задачей элемента, подвергающейся выполнению, является null
    
    IllegalArgumentException - если задачи пусты
    
    ExecutionException - если никакая задача успешно не завершается
    
    RejectedExecutionException - если задачи не могут быть запланированы для выполнения
  - invokeAny
```
<T> T invokeAny(Collection<? extends Callable<T>> tasks,
              long timeout,
              TimeUnit unit)
            throws InterruptedException,
                   ExecutionException,
                   TimeoutException
```
    Выполняет данные задачи, возвращая результат того, который завершился успешно (то есть, не выдавая исключение), если кто-либо делает прежде, чем данный тайм-аут протекает. По нормальному или исключительному возврату отменяются задачи, которые не завершились. Результаты этого метода неопределены, если данный набор изменяется, в то время как эта работа происходит.
    
    Параметры:
    tasks - набор задач
    timeout - максимальное время, чтобы ожидать
    unit - единица измерения времени параметра тайм-аута
    
    Возвраты:
    результат возвратился одной из задач.
    
    Броски:
    
    InterruptedException - если прервано, ожидая
    
    NullPointerException - если задачами, или модулем, или какой-либо задачей элемента, подвергающейся выполнению, является null
    
    TimeoutException - если данный тайм-аут протекает прежде, чем любая задача успешно завершается
    
    ExecutionException - если никакая задача успешно не завершается
    
    RejectedExecutionException - если задачи не могут быть запланированы для выполнения

Представьте ошибку или функцию
Для дальнейшей ссылки API и документации разработчика, см. Java Документация SE. Та документация содержит более подробные, предназначенные разработчиком описания, с концептуальными краткими обзорами, определениями сроков, обходных решений, и рабочих примеров кода.
Авторское право © 1993, 2011, Oracle и/или его филиалы. Все права защищены.

Интерфейсный ExecutorService

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

Сводка метода

Методы, наследованные от интерфейса java.util.concurrent. Исполнитель

Деталь метода

завершение работы

shutdownNow

isShutdown

isTerminated

awaitTermination

подчиниться

подчиниться

подчиниться

invokeAll

invokeAll

invokeAny

invokeAny