compact1, compact2, compact3

java.util.concurrent

Интерфейс ExecutorService

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

Исполнитель

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

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 class обеспечивает методы фабрики для услуг исполнителя, предоставленных в этом пакете.

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

Вот эскиз сетевой службы в который потоки в службе пула потоков входящие запросы. Это использует предварительно сконфигурированный 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 class включает ряд методов, которые могут преобразовать некоторые другие общие подобные закрытию объекты, например, 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 - если задачи не могут быть запланированы для выполнения