java.util.concurrent

Соедините интерфейсом с CompletionService <V>

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

ExecutorCompletionService

public interface CompletionService<V>

Служба, которая разъединяет производство новых асинхронных задач от потребления результатов завершенных задач. Производители задачи submit для выполнения. Потребители take завершенные задачи и процесс их результаты в порядке они завершаются. CompletionService может например использоваться, чтобы управлять асинхронным IO, в который задачи, которые выполняют чтения, представляются в одной части программы или системы, и затем действуются в различной части программы, когда чтения завершаются, возможно в различном порядке, чем их требовали.

Как правило, CompletionService полагается на отдельное Executor фактически выполнить задачи, когда CompletionService только управляет внутренней очередью завершения. ExecutorCompletionService класс обеспечивает реализацию этого подхода.

Эффекты непротиворечивости памяти: Действия в потоке до передачи задачи к a CompletionService произойдите - перед мерами, предпринятыми той задачей, которые поочередно происходят - перед действиями после успешного возврата из соответствия take().

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

Методы

Модификатор и Тип	Метод и Описание
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() Получает и удаляет Будущее, представляющее следующую завершенную задачу, ожидая, если ни один еще не присутствует.

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

подчиниться

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

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

Параметры:

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

Возвраты:

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

Броски:

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

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

подчиниться

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

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

Параметры:

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

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

Возвраты:

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

Броски:

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

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

взять

Future<V> take()
               throws InterruptedException

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

Возвраты:

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

Броски:

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

опрос

Future<V> poll()

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

Возвраты:

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

опрос

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

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

Параметры:

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

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

Возвраты:

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

Броски:

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