java.util.concurrent

Класс AbstractExecutorService

java.lang. Объект

java.util.concurrent.AbstractExecutorService

Все Реализованные Интерфейсы:

Исполнитель, Эксекуторсервайс

Прямые Известные Подклассы:

ForkJoinPool, ThreadPoolExecutor

public abstract class AbstractExecutorService
extends Object
implements ExecutorService

Обеспечивает реализации по умолчанию ExecutorService методы выполнения. Этот класс реализует submit, методы invokeAny И invokeAll, используя a RunnableFuture возвращенный newTaskFor, который значения по умолчанию к FutureTask класс обеспечил в этом пакете. Например, реализация submit(Runnable) создает связанный RunnableFuture, который выполняется и возвращается. Подклассы могут переопределить методы newTaskFor, чтобы возвратить реализации RunnableFuture кроме FutureTask.

Пример расширения. Вот эскиз класса, который настраивает ThreadPoolExecutor использовать класс CustomTask вместо FutureTask по умолчанию:

 public class CustomThreadPoolExecutor extends ThreadPoolExecutor {

   static class CustomTask<V> implements RunnableFuture<V> {...}

   protected <V> RunnableFuture<V> newTaskFor(Callable<V> c) {
       return new CustomTask<V>(c);
   }
   protected <V> RunnableFuture<V> newTaskFor(Runnable r, V v) {
       return new CustomTask<V>(r, v);
   }
   // ... add constructors, etc.
 }

С тех пор:

1.5

Сводка конструктора

Конструкторы

Конструктор и Описание
AbstractExecutorService()

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

Методы

Модификатор и Тип	Метод и Описание
<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) Выполняет данные задачи, возвращая результат того, который завершился успешно (то есть, не выдавая исключение), если кто-либо делает прежде, чем данный тайм-аут протекает.
protected <T> RunnableFuture<T>	newTaskFor(Callable<T> callable) Возвращает RunnableFuture для данной вызываемой задачи.
protected <T> RunnableFuture<T>	newTaskFor(Runnable runnable, T value) Возвращает RunnableFuture для данного выполнимого и значения по умолчанию.
<T> Future<T>	submit(Callable<T> task) Представляет возвращающую значение задачу для выполнения и возвращает Будущее, представляющее результаты на ожидании задачи.
Future<?>	submit(Runnable task) Представляет Выполнимую задачу для выполнения и возвращает Будущее, представляющее ту задачу.
<T> Future<T>	submit(Runnable task, T result) Представляет Выполнимую задачу для выполнения и возвращает Будущее, представляющее ту задачу.

Методы java.lang унаследованный от класса. Объект

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

awaitTermination, isShutdown, isTerminated, shutdown, shutdownNow

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

выполниться

Деталь конструктора

AbstractExecutorService

public AbstractExecutorService()

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

newTaskFor

protected <T> RunnableFuture<T> newTaskFor(Runnable runnable,
                               T value)

Возвращает RunnableFuture для данного выполнимого и значения по умолчанию.

Параметры:

runnable - выполнимая обертываемая задача

value - значение по умолчанию для возвращенного будущего

Возвраты:

RunnableFuture, который, когда выполненный выполнит базовое выполнимое и который, как Future, приведет к данному значению как к его результату и предусмотрит отмену базовой задачи.

С тех пор:

1.6

newTaskFor

protected <T> RunnableFuture<T> newTaskFor(Callable<T> callable)

Возвращает RunnableFuture для данной вызываемой задачи.

Параметры:

callable - вызываемая обертываемая задача

Возвраты:

RunnableFuture, который, когда выполненный вызовет базовое вызываемое и который, как Future, приведет к результату callable как к его результату и предусмотрит отмену базовой задачи.

С тех пор:

1.6

подчиниться

public Future<?> submit(Runnable task)

Описание скопировало с интерфейса: ExecutorService

Представляет Выполнимую задачу для выполнения и возвращает Будущее, представляющее ту задачу. Метод get Будущего возвратит null после успешного завершения.

Определенный:

submit в интерфейсе ExecutorService

Параметры:

task - задача подчиниться

Возвраты:

Будущее представление завершение на ожидании задачи

Броски:

RejectedExecutionException - если задача не может быть запланирована для выполнения

NullPointerException - если задачей является нуль

подчиниться

public <T> Future<T> submit(Runnable task,
                   T result)

Описание скопировало с интерфейса: ExecutorService

Представляет Выполнимую задачу для выполнения и возвращает Будущее, представляющее ту задачу. Метод get Будущего возвратит данный результат после успешного завершения.

Определенный:

submit в интерфейсе ExecutorService

Параметры:

task - задача подчиниться

result - результат возвратиться

Возвраты:

Будущее представление завершение на ожидании задачи

Броски:

RejectedExecutionException - если задача не может быть запланирована для выполнения

NullPointerException - если задачей является нуль

подчиниться

public <T> Future<T> submit(Callable<T> task)

Описание скопировало с интерфейса: ExecutorService

Представляет возвращающую значение задачу для выполнения и возвращает Будущее, представляющее результаты на ожидании задачи. Метод get Будущего возвратит результат задачи после успешного завершения.

Если требуется сразу блокировать ожидание задачи, можно использовать конструкции формы result = exec.submit(aCallable).get();

Отметьте: Executors класс включает ряд методов, которые могут преобразовать некоторые другие общие подобные закрытию объекты, например, PrivilegedAction к Callable сформируйтесь, таким образом, они могут быть представлены.

Определенный:

submit в интерфейсе ExecutorService

Параметры:

task - задача подчиниться

Возвраты:

Будущее представление завершение на ожидании задачи

Броски:

RejectedExecutionException - если задача не может быть запланирована для выполнения

NullPointerException - если задачей является нуль

invokeAny

public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
            throws InterruptedException,
                   ExecutionException

Описание скопировало с интерфейса: ExecutorService

Выполняет данные задачи, возвращая результат того, который завершился успешно (то есть, не выдавая исключение), если кто-либо делает. По нормальному или исключительному возврату отменяются задачи, которые не завершились. Результаты этого метода неопределены, если данный набор изменяется, в то время как эта работа происходит.

Определенный:

invokeAny в интерфейсе ExecutorService

Параметры:

tasks - набор задач

Возвраты:

результат возвратился одной из задач

Броски:

InterruptedException - если прервано, ожидая

ExecutionException - если никакая задача успешно не завершается

invokeAny

public <T> T invokeAny(Collection<? extends Callable<T>> tasks,
              long timeout,
              TimeUnit unit)
            throws InterruptedException,
                   ExecutionException,
                   TimeoutException

Описание скопировало с интерфейса: ExecutorService

Выполняет данные задачи, возвращая результат того, который завершился успешно (то есть, не выдавая исключение), если кто-либо делает прежде, чем данный тайм-аут протекает. По нормальному или исключительному возврату отменяются задачи, которые не завершились. Результаты этого метода неопределены, если данный набор изменяется, в то время как эта работа происходит.

Определенный:

invokeAny в интерфейсе ExecutorService

Параметры:

tasks - набор задач

timeout - максимальное время, чтобы ожидать

unit - единица измерения времени параметра тайм-аута

Возвраты:

результат возвратился одной из задач.

Броски:

InterruptedException - если прервано, ожидая

ExecutionException - если никакая задача успешно не завершается

TimeoutException - если данный тайм-аут протекает прежде, чем любая задача успешно завершается

invokeAll

public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
                          throws InterruptedException

Описание скопировало с интерфейса: ExecutorService

Выполняет данные задачи, возвращая список Фьючерса, содержащего их состояние, и заканчивается, когда все завершаются. Future.isDone() true для каждого элемента возвращенного списка. Отметьте, что завершенная задача, возможно, завершилась или обычно или выдавая исключение. Результаты этого метода неопределены, если данный набор изменяется, в то время как эта работа происходит.

Определенный:

invokeAll в интерфейсе ExecutorService

Параметры:

tasks - набор задач

Возвраты:

Список Фьючерса, представляющего задачи, в том же самом последовательном порядке как произведено iterator для данного списка задач, каждый из которых завершился.

Броски:

InterruptedException - если прервано, ожидая, когда отменяются незаконченные задачи.

invokeAll

public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
                            long timeout,
                            TimeUnit unit)
                          throws InterruptedException

Описание скопировало с интерфейса: ExecutorService

Выполняет данные задачи, возвращая список Фьючерса, содержащего их состояние, и заканчивается, когда все завершаются, или тайм-аут истекает, какой бы ни происходит сначала. Future.isDone() true для каждого элемента возвращенного списка. По возврату отменяются задачи, которые не завершились. Отметьте, что завершенная задача, возможно, завершилась или обычно или выдавая исключение. Результаты этого метода неопределены, если данный набор изменяется, в то время как эта работа происходит.

Определенный:

invokeAll в интерфейсе ExecutorService

Параметры:

tasks - набор задач

timeout - максимальное время, чтобы ожидать

unit - единица измерения времени параметра тайм-аута

Возвраты:

список Фьючерса, представляющего задачи, в том же самом последовательном порядке как произведено iterator для данного списка задач. Если работа убирала не время, каждая задача завершится. Если это отбывало срок, некоторые из этих задач не будут завершаться.

Броски:

InterruptedException - если прервано, ожидая, когда отменяются незаконченные задачи