java.util.concurrent

Класс ExecutorCompletionService <V>

java.lang. Объект

java.util.concurrent.ExecutorCompletionService<V>

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

CompletionService <V>

public class ExecutorCompletionService<V>
extends Object
implements CompletionService<V>

A CompletionService это использует предоставленный Executor выполнить задачи. Этот класс расположения, которые представили задачи, после завершения, помещенного в очередь доступное использование take. Класс достаточно легок, чтобы быть подходящим для переходного использования, обрабатывая группы задач.

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

 void solve(Executor e,
            Collection<Callable<Result>> solvers)
     throws InterruptedException, ExecutionException {
     CompletionService<Result> ecs
         = new ExecutorCompletionService<Result>(e);
     for (Callable<Result> s : solvers)
         ecs.submit(s);
     int n = solvers.size();
     for (int i = 0; i < n; ++i) {
         Result r = ecs.take().get();
         if (r != null)
             use(r);
     }
 }

Предположите вместо этого, что требуется использовать первый ненулевой результат набора задач, игнорируя любого, которые встречаются с исключениями, и отменяющий все другие задачи, когда первый готов:

 void solve(Executor e,
            Collection<Callable<Result>> solvers)
     throws InterruptedException {
     CompletionService<Result> ecs
         = new ExecutorCompletionService<Result>(e);
     int n = solvers.size();
     List<Future<Result>> futures
         = new ArrayList<Future<Result>>(n);
     Result result = null;
     try {
         for (Callable<Result> s : solvers)
             futures.add(ecs.submit(s));
         for (int i = 0; i < n; ++i) {
             try {
                 Result r = ecs.take().get();
                 if (r != null) {
                     result = r;
                     break;
                 }
             } catch (ExecutionException ignore) {}
         }
     }
     finally {
         for (Future<Result> f : futures)
             f.cancel(true);
     }

     if (result != null)
         use(result);
 }

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

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

Конструктор и Описание
ExecutorCompletionService(Executor executor) Создает ExecutorCompletionService, используя предоставленного исполнителя для основного выполнения задачи и a LinkedBlockingQueue как очередь завершения.
ExecutorCompletionService(Executor executor, BlockingQueue<Future<V>> completionQueue) Создает ExecutorCompletionService, используя предоставленного исполнителя для основного выполнения задачи и предоставленную очередь как ее очередь завершения.

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

Методы

Модификатор и Тип	Метод и Описание
Future<V>	poll() Получает и удаляет Будущее, представляющее следующую завершенную задачу или null, если ни один не присутствует.
Future<V>	poll(long timeout, TimeUnit unit) Получает и удаляет Будущее, представляющее следующую завершенную задачу, ожидая в случае необходимости до указанного времени ожидания, если ни один еще не присутствует.
Future<V>	submit(Callable<V> task) Представляет возвращающую значение задачу для выполнения и возвращает Будущее, представляющее результаты на ожидании задачи.
Future<V>	submit(Runnable task, V result) Представляет Выполнимую задачу для выполнения и возвращает Будущее, представляющее ту задачу.
Future<V>	take() Получает и удаляет Будущее, представляющее следующую завершенную задачу, ожидая, если ни один еще не присутствует.

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

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

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

ExecutorCompletionService

public ExecutorCompletionService(Executor executor)

Создает ExecutorCompletionService, используя предоставленного исполнителя для основного выполнения задачи и a LinkedBlockingQueue как очередь завершения.

Параметры:

executor - исполнитель, чтобы использовать

Броски:

NullPointerException - если исполнитель null

ExecutorCompletionService

public ExecutorCompletionService(Executor executor,
                         BlockingQueue<Future<V>> completionQueue)

Создает ExecutorCompletionService, используя предоставленного исполнителя для основного выполнения задачи и предоставленную очередь как ее очередь завершения.

Параметры:

executor - исполнитель, чтобы использовать

completionQueue - очередь, чтобы обычно использовать в качестве очереди завершения один выделенный для использования этой службой. Эта очередь обрабатывается как неограниченная - отказавший предпринятый Queue.add операции для завершенного taskes заставляют их не быть восстановимыми.

Броски:

NullPointerException - если исполнитель или completionQueue null

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

подчиниться

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

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

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

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

submit в интерфейсе CompletionService<V>

Параметры:

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

Возвраты:

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

подчиниться

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

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

Представляет Выполнимую задачу для выполнения и возвращает Будущее, представляющее ту задачу. После завершения эта задача может быть взята или опрошена.

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

submit в интерфейсе CompletionService<V>

Параметры:

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

result - результат возвратиться после успешного завершения

Возвраты:

завершение Будущего представления на ожидании задачи, и чей метод get() возвратит данное значение результата после завершения

взять

public Future<V> take()
               throws InterruptedException

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

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

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

take в интерфейсе CompletionService<V>

Возвраты:

Будущее, представляющее следующую завершенную задачу

Броски:

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

опрос

public Future<V> poll()

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

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

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

poll в интерфейсе CompletionService<V>

Возвраты:

Будущее, представляющее следующую завершенную задачу, или null, если ни один не присутствует

опрос

public Future<V> poll(long timeout,
             TimeUnit unit)
               throws InterruptedException

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

Получает и удаляет Будущее, представляющее следующую завершенную задачу, ожидая в случае необходимости до указанного времени ожидания, если ни один еще не присутствует.

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

poll в интерфейсе CompletionService<V>

Параметры:

timeout - сколько времени ожидать перед отказом в модулях unit

unit - TimeUnit, определяющий, как интерпретировать параметр timeout

Возвраты:

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

Броски:

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