compact1, compact2, compact3

java.util.concurrent

Класс CompletableFuture <T>

java.lang. Объект

java.util.concurrent.CompletableFuture<T>

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

Будущее <T>

public class CompletableFuture<T>
extends Object
implements Future<T>

A Future это может быть явно завершено (установка его значения и состояния), и может включать зависимые функции и действия, которые инициировали после его завершения.

Когда два или больше потока пытаются к complete, completeExceptionally, или cancel CompletableFuture, только один из них успешно выполняется.

Методы доступны для добавления иждивенцев, основанных на предоставленных пользователем Функциях, Потребителях, или Runnables. Соответствующая форма, чтобы использовать зависит от того, требуют ли действия параметров и/или приводят к результатам. Завершение зависимого действия инициирует завершение другого CompletableFuture. Действия могут также быть инициированы после или или и ток и другой полный CompletableFuture. Многократный CompletableFutures может также быть сгруппирован как одно использование anyOf(CompletableFuture...) и allOf(CompletableFuture...).

Сами CompletableFutures не выполняются асинхронно. Однако, действия, предоставленные для зависимых завершений другого CompletableFuture, могут сделать так, в зависимости от того, обеспечивают ли им через один из асинхронных методов (то есть, методов с именами формы xxxAsync). Асинхронные методы обеспечивают способ начать асинхронную обработку действия, используя любого данный Executor или по умолчанию ForkJoinPool.commonPool(). Чтобы упростить контроль, отладку, и отслеживание, всеми сгенерированными асинхронными задачами являются экземпляры интерфейса маркера CompletableFuture.AsynchronousCompletionTask.

Действия, предоставленные для зависимых завершений неасинхронных методов, могут быть выполнены потоком, который завершает текущий CompletableFuture, или любой другой вызывающей стороной этих методов. Нет никаких гарантий о порядке обработки завершений если не ограничено этими методами.

С тех пор (в отличие от этого FutureTask) у этого class нет никакого прямого управления вычислением, которое заставляет его быть завершенным, отмена обрабатывается как только другая форма исключительного завершения. Метод cancel имеет тот же самый эффект как completeExceptionally(new CancellationException()).

После исключительного завершения (включая отмену), или когда завершение влечет за собой дополнительное вычисление, которое завершается резко с исключением (непроверенным) или ошибкой, тогда все их зависимые завершения (и их иждивенцы поочередно) обычно действуют как completeExceptionally с a CompletionException содержание того исключения как его причина. Однако, exceptionally и handle завершения в состоянии обработать исключительные завершения CompletableFutures, от которого они зависят.

В случае исключительного завершения с CompletionException, методами get() и get(long, TimeUnit) бросьте ExecutionException с той же самой причиной как сохранено в соответствующем CompletionException. Однако, в этих случаях, методах join() и getNow(T) бросьте CompletionException, который упрощает использование.

Параметры, используемые, чтобы передать результат завершения (то есть, для параметров типа T) может быть нуль, но передача нулевого значения для любого другого параметра приведет к a NullPointerException быть брошенным.

С тех пор:

1.8

Вложенная Сводка Класса

Вложенные Классы

Модификатор и Тип	Класс и Описание
static interface	CompletableFuture.AsynchronousCompletionTask Интерфейс маркера, идентифицирующий асинхронные задачи, произведенные async методы.

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

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

Конструктор и Описание
CompletableFuture() Создает новый неполный CompletableFuture.

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

Модификатор и Тип	Метод и Описание
CompletableFuture<Void>	acceptEither(CompletableFuture<? extends T> other, Consumer<? super T> block) Возвращает новый CompletableFuture, который завершается, когда или это или другой данный CompletableFuture завершаются после выполнения данного действия с результатом или этого или результата другого CompletableFuture.
CompletableFuture<Void>	acceptEitherAsync(CompletableFuture<? extends T> other, Consumer<? super T> block) Возвращает новый CompletableFuture, который асинхронно завершается, когда или это или другой данный CompletableFuture завершаются после выполнения данного действия с результатом или этого или следствия другого CompletableFuture задачи, работающей в ForkJoinPool.commonPool().
CompletableFuture<Void>	acceptEitherAsync(CompletableFuture<? extends T> other, Consumer<? super T> block, Executor executor) Возвращает новый CompletableFuture, который асинхронно завершается, когда или это или другой данный CompletableFuture завершаются после выполнения данного действия с результатом или этого или следствия другого CompletableFuture задачи, работающей в данном исполнителе.
static CompletableFuture<Void>	allOf(CompletableFuture<?>... cfs) Возвращает новый CompletableFuture, который завершается, когда все данные CompletableFutures завершаются.
static CompletableFuture<Object>	anyOf(CompletableFuture<?>... cfs) Возвращает новый CompletableFuture, который завершается когда любой из данных полных CompletableFutures с тем же самым результатом.
<U> CompletableFuture<U>	applyToEither(CompletableFuture<? extends T> other, Function<? super T,U> fn) Возвращает новый CompletableFuture, который завершается, когда или это или другой данный CompletableFuture завершаются с результатом заданной функции или этого или результата другого CompletableFuture.
<U> CompletableFuture<U>	applyToEitherAsync(CompletableFuture<? extends T> other, Function<? super T,U> fn) Возвращает новый CompletableFuture, который асинхронно завершается, когда или это или другой данный CompletableFuture завершаются с результатом заданной функции или этого или следствия другого CompletableFuture задачи, работающей в ForkJoinPool.commonPool().
<U> CompletableFuture<U>	applyToEitherAsync(CompletableFuture<? extends T> other, Function<? super T,U> fn, Executor executor) Возвращает новый CompletableFuture, который асинхронно завершается, когда или это или другой данный CompletableFuture завершаются с результатом заданной функции или этого или следствия другого CompletableFuture задачи, работающей в данном исполнителе.
boolean	cancel(boolean mayInterruptIfRunning) Если не уже завершенный, завершает этот CompletableFuture с a CancellationException.
boolean	complete(T value) Если не уже завершенный, устанавливает значение, возвращенное get() и связанные методы к данному значению.
static <U> CompletableFuture<U>	completedFuture(U value) Возвращает новый CompletableFuture, который уже завершается с данным значением.
boolean	completeExceptionally(Throwable ex) Если не уже завершенный, вызовы причин get() и связанные методы, чтобы выдать данное исключение.
CompletableFuture<T>	exceptionally(Function<Throwable,? extends T> fn) Возвращает новый CompletableFuture, который завершается, когда этот CompletableFuture завершается с результатом заданной функции исключения, инициировавшего завершение этого CompletableFuture, когда это завершается исключительно; иначе, если этот CompletableFuture обычно завершается, то возвращенный CompletableFuture также обычно завершается с тем же самым значением.
T	get() Ожидает в случае необходимости этого будущего, чтобы завершиться, и затем возвращает его результат.
T	get(long timeout, TimeUnit unit) Ожидает в случае необходимости в течение самое большее данного времени для этого будущего, чтобы завершиться, и затем возвращает его результат, при наличии.
T	getNow(T valueIfAbsent) Возвращает значение результата (или выдает любое исключение, с которым встречаются), если завершено, еще возвращает данный valueIfAbsent.
int	getNumberOfDependents() Возвращает предполагаемое число CompletableFutures, завершения которого ждут завершения этого CompletableFuture.
<U> CompletableFuture<U>	handle(BiFunction<? super T,Throwable,? extends U> fn) Возвращает новый CompletableFuture, который завершается, когда этот CompletableFuture завершается с результатом заданной функции результата и исключения завершения этого CompletableFuture.
boolean	isCancelled() Возвраты true если этот CompletableFuture был отменен прежде, чем он обычно завершался.
boolean	isDone() Возвраты true если завершено любым способом: обычно, исключительно, или через отмену.
T	join() Возвращает значение результата когда завершено, или выдает исключение (непроверенное) если завершено исключительно.
void	obtrudeException(Throwable ex) Насильственно вызывает последующие вызовы метода get() и связанные методы, чтобы выдать данное исключение, действительно ли уже завершенный.
void	obtrudeValue(T value) Насильственно наборы или сбросы значение впоследствии возвратились методом get() и связанные методы, действительно ли уже завершенный.
CompletableFuture<Void>	runAfterBoth(CompletableFuture<?> other, Runnable action) Возвращает новый CompletableFuture, который завершается когда и это и другой данный полный CompletableFuture после выполнения данного действия.
CompletableFuture<Void>	runAfterBothAsync(CompletableFuture<?> other, Runnable action) Возвращает новый CompletableFuture, который асинхронно завершается когда и это и другой данный полный CompletableFuture после выполнения данного действия от задачи, работающей в ForkJoinPool.commonPool().
CompletableFuture<Void>	runAfterBothAsync(CompletableFuture<?> other, Runnable action, Executor executor) Возвращает новый CompletableFuture, который асинхронно завершается когда и это и другой данный полный CompletableFuture после выполнения данного действия от задачи, работающей в данном исполнителе.
CompletableFuture<Void>	runAfterEither(CompletableFuture<?> other, Runnable action) Возвращает новый CompletableFuture, который завершается, когда или это или другой данный CompletableFuture завершаются после выполнения данного действия.
CompletableFuture<Void>	runAfterEitherAsync(CompletableFuture<?> other, Runnable action) Возвращает новый CompletableFuture, который асинхронно завершается, когда или это или другой данный CompletableFuture завершаются после выполнения данного действия от задачи, работающей в ForkJoinPool.commonPool().
CompletableFuture<Void>	runAfterEitherAsync(CompletableFuture<?> other, Runnable action, Executor executor) Возвращает новый CompletableFuture, который асинхронно завершается, когда или это или другой данный CompletableFuture завершаются после выполнения данного действия от задачи, работающей в данном исполнителе.
static CompletableFuture<Void>	runAsync(Runnable runnable) Возвращает новый CompletableFuture, который асинхронно завершается задачей, работающей в ForkJoinPool.commonPool() после того, как это выполняет данное действие.
static CompletableFuture<Void>	runAsync(Runnable runnable, Executor executor) Возвращает новый CompletableFuture, который асинхронно завершается задачей, работающей в данном исполнителе после того, как это выполняет данное действие.
static <U> CompletableFuture<U>	supplyAsync(Supplier<U> supplier) Возвращает новый CompletableFuture, который асинхронно завершается задачей, работающей в ForkJoinPool.commonPool() со значением, полученным, вызывая данного Поставщика.
static <U> CompletableFuture<U>	supplyAsync(Supplier<U> supplier, Executor executor) Возвращает новый CompletableFuture, который асинхронно завершается задачей, работающей в данном исполнителе со значением, полученным, вызывая данного Поставщика.
CompletableFuture<Void>	thenAccept(Consumer<? super T> block) Возвращает новый CompletableFuture, который завершается, когда этот CompletableFuture завершается после выполнения данного действия с результатом этого CompletableFuture.
CompletableFuture<Void>	thenAcceptAsync(Consumer<? super T> block) Возвращает новый CompletableFuture, который асинхронно завершается, когда этот CompletableFuture завершается после выполнения данного действия со следствием этого CompletableFuture задачи, работающей в ForkJoinPool.commonPool().
CompletableFuture<Void>	thenAcceptAsync(Consumer<? super T> block, Executor executor) Возвращает новый CompletableFuture, который асинхронно завершается, когда этот CompletableFuture завершается после выполнения данного действия со следствием этого CompletableFuture задачи, работающей в данном исполнителе.
<U> CompletableFuture<Void>	thenAcceptBoth(CompletableFuture<? extends U> other, BiConsumer<? super T,? super U> block) Возвращает новый CompletableFuture, который завершается когда и это и другой данный полный CompletableFuture после выполнения данного действия с результатами двух CompletableFutures.
<U> CompletableFuture<Void>	thenAcceptBothAsync(CompletableFuture<? extends U> other, BiConsumer<? super T,? super U> block) Возвращает новый CompletableFuture, который асинхронно завершается когда и это и другой данный полный CompletableFuture после выполнения данного действия с результатами двух CompletableFutures от задачи, работающей в ForkJoinPool.commonPool().
<U> CompletableFuture<Void>	thenAcceptBothAsync(CompletableFuture<? extends U> other, BiConsumer<? super T,? super U> block, Executor executor) Возвращает новый CompletableFuture, который асинхронно завершается когда и это и другой данный полный CompletableFuture после выполнения данного действия с результатами двух CompletableFutures от задачи, работающей в данном исполнителе.
<U> CompletableFuture<U>	thenApply(Function<? super T,? extends U> fn) Возвращает новый CompletableFuture, который завершается, когда этот CompletableFuture завершается с результатом заданной функции результата этого CompletableFuture.
<U> CompletableFuture<U>	thenApplyAsync(Function<? super T,? extends U> fn) Возвращает новый CompletableFuture, который асинхронно завершается, когда этот CompletableFuture завершается с результатом заданной функции следствия этого CompletableFuture задачи, работающей в ForkJoinPool.commonPool().
<U> CompletableFuture<U>	thenApplyAsync(Function<? super T,? extends U> fn, Executor executor) Возвращает новый CompletableFuture, который асинхронно завершается, когда этот CompletableFuture завершается с результатом заданной функции следствия этого CompletableFuture задачи, работающей в данном исполнителе.
<U,V> CompletableFuture<V>	thenCombine(CompletableFuture<? extends U> other, BiFunction<? super T,? super U,? extends V> fn) Возвращает новый CompletableFuture, который завершается когда и это и другой данный полный CompletableFuture с результатом заданной функции результатов двух CompletableFutures.
<U,V> CompletableFuture<V>	thenCombineAsync(CompletableFuture<? extends U> other, BiFunction<? super T,? super U,? extends V> fn) Возвращает новый CompletableFuture, который асинхронно завершается когда и это и другой данный полный CompletableFuture с результатом заданной функции результатов двух CompletableFutures от задачи, работающей в ForkJoinPool.commonPool().
<U,V> CompletableFuture<V>	thenCombineAsync(CompletableFuture<? extends U> other, BiFunction<? super T,? super U,? extends V> fn, Executor executor) Возвращает новый CompletableFuture, который асинхронно завершается когда и это и другой данный полный CompletableFuture с результатом заданной функции результатов двух CompletableFutures от задачи, работающей в данном исполнителе.
<U> CompletableFuture<U>	thenCompose(Function<? super T,CompletableFuture<U>> fn) Возвращает CompletableFuture, что после завершения, имеет то же самое значение как произведено заданной функцией результата этого CompletableFuture.
<U> CompletableFuture<U>	thenComposeAsync(Function<? super T,CompletableFuture<U>> fn) Возвращает CompletableFuture, что после завершения, имеет то же самое значение, как это произвело асинхронно использование ForkJoinPool.commonPool() заданной функцией результата этого CompletableFuture.
<U> CompletableFuture<U>	thenComposeAsync(Function<? super T,CompletableFuture<U>> fn, Executor executor) Возвращает CompletableFuture, что после завершения, имеет то же самое значение, как это произвело асинхронно использование данного исполнителя заданной функцией этого CompletableFuture.
CompletableFuture<Void>	thenRun(Runnable action) Возвращает новый CompletableFuture, который завершается, когда этот CompletableFuture завершается после выполнения данного действия.
CompletableFuture<Void>	thenRunAsync(Runnable action) Возвращает новый CompletableFuture, который асинхронно завершается, когда этот CompletableFuture завершается после выполнения данного действия от задачи, работающей в ForkJoinPool.commonPool().
CompletableFuture<Void>	thenRunAsync(Runnable action, Executor executor) Возвращает новый CompletableFuture, который асинхронно завершается, когда этот CompletableFuture завершается после выполнения данного действия от задачи, работающей в данном исполнителе.
Строка	toString() Возвращает строку, идентифицирующую этот CompletableFuture, так же как его состояние завершения.

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

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

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

CompletableFuture

public CompletableFuture()

Создает новый неполный CompletableFuture.

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

supplyAsync

public static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier)

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

Параметры:

supplier - функция, возвращая значение, которое будет использоваться, чтобы завершить возвращенный CompletableFuture

Возвраты:

новый CompletableFuture

supplyAsync

public static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier,
                                                   Executor executor)

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

Параметры:

supplier - функция, возвращая значение, которое будет использоваться, чтобы завершить возвращенный CompletableFuture

executor - исполнитель, чтобы использовать для асинхронного выполнения

Возвраты:

новый CompletableFuture

runAsync

public static CompletableFuture<Void> runAsync(Runnable runnable)

Возвращает новый CompletableFuture, который асинхронно завершается задачей, работающей в ForkJoinPool.commonPool() после того, как это выполняет данное действие.

Параметры:

runnable - действие, чтобы работать прежде, чем завершить возвращенный CompletableFuture

Возвраты:

новый CompletableFuture

runAsync

public static CompletableFuture<Void> runAsync(Runnable runnable,
                                               Executor executor)

Возвращает новый CompletableFuture, который асинхронно завершается задачей, работающей в данном исполнителе после того, как это выполняет данное действие.

Параметры:

runnable - действие, чтобы работать прежде, чем завершить возвращенный CompletableFuture

executor - исполнитель, чтобы использовать для асинхронного выполнения

Возвраты:

новый CompletableFuture

completedFuture

public static <U> CompletableFuture<U> completedFuture(U value)

Возвращает новый CompletableFuture, который уже завершается с данным значением.

Параметры:

value - значение

Возвраты:

завершенный CompletableFuture

isDone

public boolean isDone()

Возвраты true если завершено любым способом: обычно, исключительно, или через отмену.

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

isDone в интерфейсе Future<T>

Возвраты:

true если завершено

добраться

public T get()
      throws InterruptedException,
             ExecutionException

Ожидает в случае необходимости этого будущего, чтобы завершиться, и затем возвращает его результат.

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

get в интерфейсе Future<T>

Возвраты:

значение результата

Броски:

CancellationException - если это будущее было отменено

ExecutionException - если это будущее завершалось исключительно

InterruptedException - если текущий поток был прерван, ожидая

добраться

public T get(long timeout,
             TimeUnit unit)
      throws InterruptedException,
             ExecutionException,
             TimeoutException

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

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

get в интерфейсе Future<T>

Параметры:

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

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

Возвраты:

значение результата

Броски:

CancellationException - если это будущее было отменено

ExecutionException - если это будущее завершалось исключительно

InterruptedException - если текущий поток был прерван, ожидая

TimeoutException - если ожидание синхронизированного

соединение

public T join()

Возвращает значение результата когда завершено, или выдает исключение (непроверенное) если завершено исключительно. Чтобы лучше соответствовать использованию общих функциональных форм, если вычисление, включенное в завершение этого CompletableFuture, выдавало исключение, этот метод бросает (непроверенный) CompletionException с базовым исключением как его причина.

Возвраты:

значение результата

Броски:

CancellationException - если вычисление было отменено

CompletionException - если это будущее завершалось исключительно, или вычисление завершения выдавало исключение

getNow

public T getNow(T valueIfAbsent)

Возвращает значение результата (или выдает любое исключение, с которым встречаются), если завершено, еще возвращает данный valueIfAbsent.

Параметры:

valueIfAbsent - значение, чтобы возвратиться, если не завершенный

Возвраты:

значение результата, если завершено, еще данный valueIfAbsent

Броски:

CancellationException - если вычисление было отменено

CompletionException - если это будущее завершалось исключительно, или вычисление завершения выдавало исключение

полный

public boolean complete(T value)

Если не уже завершенный, устанавливает значение, возвращенное get() и связанные методы к данному значению.

Параметры:

value - значение результата

Возвраты:

true если этот вызов, вызванный этот CompletableFuture к переходу к завершенному состоянию, еще false

completeExceptionally

public boolean completeExceptionally(Throwable ex)

Если не уже завершенный, вызовы причин get() и связанные методы, чтобы выдать данное исключение.

Параметры:

ex - исключение

Возвраты:

true если этот вызов, вызванный этот CompletableFuture к переходу к завершенному состоянию, еще false

thenApply

public <U> CompletableFuture<U> thenApply(Function<? super T,? extends U> fn)

Возвращает новый CompletableFuture, который завершается, когда этот CompletableFuture завершается с результатом заданной функции результата этого CompletableFuture.

Если этот CompletableFuture завершается исключительно, или предоставленная функция выдает исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

fn - функция, чтобы использовать, чтобы вычислить значение возвращенного CompletableFuture

Возвраты:

новый CompletableFuture

thenApplyAsync

public <U> CompletableFuture<U> thenApplyAsync(Function<? super T,? extends U> fn)

Возвращает новый CompletableFuture, который асинхронно завершается, когда этот CompletableFuture завершается с результатом заданной функции следствия этого CompletableFuture задачи, работающей в ForkJoinPool.commonPool().

Если этот CompletableFuture завершается исключительно, или предоставленная функция выдает исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

fn - функция, чтобы использовать, чтобы вычислить значение возвращенного CompletableFuture

Возвраты:

новый CompletableFuture

thenApplyAsync

public <U> CompletableFuture<U> thenApplyAsync(Function<? super T,? extends U> fn,
                                               Executor executor)

Возвращает новый CompletableFuture, который асинхронно завершается, когда этот CompletableFuture завершается с результатом заданной функции следствия этого CompletableFuture задачи, работающей в данном исполнителе.

Если этот CompletableFuture завершается исключительно, или предоставленная функция выдает исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

fn - функция, чтобы использовать, чтобы вычислить значение возвращенного CompletableFuture

executor - исполнитель, чтобы использовать для асинхронного выполнения

Возвраты:

новый CompletableFuture

thenAccept

public CompletableFuture<Void> thenAccept(Consumer<? super T> block)

Возвращает новый CompletableFuture, который завершается, когда этот CompletableFuture завершается после выполнения данного действия с результатом этого CompletableFuture.

Если этот CompletableFuture завершается исключительно, или предоставленное действие выдает исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

block - действие, чтобы выполнить прежде, чем завершить возвращенный CompletableFuture

Возвраты:

новый CompletableFuture

thenAcceptAsync

public CompletableFuture<Void> thenAcceptAsync(Consumer<? super T> block)

Возвращает новый CompletableFuture, который асинхронно завершается, когда этот CompletableFuture завершается после выполнения данного действия со следствием этого CompletableFuture задачи, работающей в ForkJoinPool.commonPool().

Если этот CompletableFuture завершается исключительно, или предоставленное действие выдает исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

block - действие, чтобы выполнить прежде, чем завершить возвращенный CompletableFuture

Возвраты:

новый CompletableFuture

thenAcceptAsync

public CompletableFuture<Void> thenAcceptAsync(Consumer<? super T> block,
                                               Executor executor)

Возвращает новый CompletableFuture, который асинхронно завершается, когда этот CompletableFuture завершается после выполнения данного действия со следствием этого CompletableFuture задачи, работающей в данном исполнителе.

Если этот CompletableFuture завершается исключительно, или предоставленное действие выдает исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

block - действие, чтобы выполнить прежде, чем завершить возвращенный CompletableFuture

executor - исполнитель, чтобы использовать для асинхронного выполнения

Возвраты:

новый CompletableFuture

thenRun

public CompletableFuture<Void> thenRun(Runnable action)

Возвращает новый CompletableFuture, который завершается, когда этот CompletableFuture завершается после выполнения данного действия.

Если этот CompletableFuture завершается исключительно, или предоставленное действие выдает исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

action - действие, чтобы выполнить прежде, чем завершить возвращенный CompletableFuture

Возвраты:

новый CompletableFuture

thenRunAsync

public CompletableFuture<Void> thenRunAsync(Runnable action)

Возвращает новый CompletableFuture, который асинхронно завершается, когда этот CompletableFuture завершается после выполнения данного действия от задачи, работающей в ForkJoinPool.commonPool().

Если этот CompletableFuture завершается исключительно, или предоставленное действие выдает исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

action - действие, чтобы выполнить прежде, чем завершить возвращенный CompletableFuture

Возвраты:

новый CompletableFuture

thenRunAsync

public CompletableFuture<Void> thenRunAsync(Runnable action,
                                            Executor executor)

Возвращает новый CompletableFuture, который асинхронно завершается, когда этот CompletableFuture завершается после выполнения данного действия от задачи, работающей в данном исполнителе.

Если этот CompletableFuture завершается исключительно, или предоставленное действие выдает исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

action - действие, чтобы выполнить прежде, чем завершить возвращенный CompletableFuture

executor - исполнитель, чтобы использовать для асинхронного выполнения

Возвраты:

новый CompletableFuture

thenCombine

public <U,V> CompletableFuture<V> thenCombine(CompletableFuture<? extends U> other,
                                              BiFunction<? super T,? super U,? extends V> fn)

Возвращает новый CompletableFuture, который завершается когда и это и другой данный полный CompletableFuture с результатом заданной функции результатов двух CompletableFutures.

Если это и/или другой CompletableFuture, полный исключительно, или предоставленная функция, выдают исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

other - другой CompletableFuture

fn - функция, чтобы использовать, чтобы вычислить значение возвращенного CompletableFuture

Возвраты:

новый CompletableFuture

thenCombineAsync

public <U,V> CompletableFuture<V> thenCombineAsync(CompletableFuture<? extends U> other,
                                                   BiFunction<? super T,? super U,? extends V> fn)

Возвращает новый CompletableFuture, который асинхронно завершается когда и это и другой данный полный CompletableFuture с результатом заданной функции результатов двух CompletableFutures от задачи, работающей в ForkJoinPool.commonPool().

Если это и/или другой CompletableFuture, полный исключительно, или предоставленная функция, выдают исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

other - другой CompletableFuture

fn - функция, чтобы использовать, чтобы вычислить значение возвращенного CompletableFuture

Возвраты:

новый CompletableFuture

thenCombineAsync

public <U,V> CompletableFuture<V> thenCombineAsync(CompletableFuture<? extends U> other,
                                                   BiFunction<? super T,? super U,? extends V> fn,
                                                   Executor executor)

Возвращает новый CompletableFuture, который асинхронно завершается когда и это и другой данный полный CompletableFuture с результатом заданной функции результатов двух CompletableFutures от задачи, работающей в данном исполнителе.

Если это и/или другой CompletableFuture, полный исключительно, или предоставленная функция, выдают исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

other - другой CompletableFuture

fn - функция, чтобы использовать, чтобы вычислить значение возвращенного CompletableFuture

executor - исполнитель, чтобы использовать для асинхронного выполнения

Возвраты:

новый CompletableFuture

thenAcceptBoth

public <U> CompletableFuture<Void> thenAcceptBoth(CompletableFuture<? extends U> other,
                                                  BiConsumer<? super T,? super U> block)

Возвращает новый CompletableFuture, который завершается когда и это и другой данный полный CompletableFuture после выполнения данного действия с результатами двух CompletableFutures.

Если это и/или другой CompletableFuture, полный исключительно, или предоставленное действие, выдают исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

other - другой CompletableFuture

block - действие, чтобы выполнить прежде, чем завершить возвращенный CompletableFuture

Возвраты:

новый CompletableFuture

thenAcceptBothAsync

public <U> CompletableFuture<Void> thenAcceptBothAsync(CompletableFuture<? extends U> other,
                                                       BiConsumer<? super T,? super U> block)

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

Если это и/или другой CompletableFuture, полный исключительно, или предоставленное действие, выдают исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

other - другой CompletableFuture

block - действие, чтобы выполнить прежде, чем завершить возвращенный CompletableFuture

Возвраты:

новый CompletableFuture

thenAcceptBothAsync

public <U> CompletableFuture<Void> thenAcceptBothAsync(CompletableFuture<? extends U> other,
                                                       BiConsumer<? super T,? super U> block,
                                                       Executor executor)

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

Если это и/или другой CompletableFuture, полный исключительно, или предоставленное действие, выдают исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

other - другой CompletableFuture

block - действие, чтобы выполнить прежде, чем завершить возвращенный CompletableFuture

executor - исполнитель, чтобы использовать для асинхронного выполнения

Возвраты:

новый CompletableFuture

runAfterBoth

public CompletableFuture<Void> runAfterBoth(CompletableFuture<?> other,
                                            Runnable action)

Возвращает новый CompletableFuture, который завершается когда и это и другой данный полный CompletableFuture после выполнения данного действия.

Если это и/или другой CompletableFuture, полный исключительно, или предоставленное действие, выдают исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

other - другой CompletableFuture

action - действие, чтобы выполнить прежде, чем завершить возвращенный CompletableFuture

Возвраты:

новый CompletableFuture

runAfterBothAsync

public CompletableFuture<Void> runAfterBothAsync(CompletableFuture<?> other,
                                                 Runnable action)

Возвращает новый CompletableFuture, который асинхронно завершается когда и это и другой данный полный CompletableFuture после выполнения данного действия от задачи, работающей в ForkJoinPool.commonPool().

Если это и/или другой CompletableFuture, полный исключительно, или предоставленное действие, выдают исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

other - другой CompletableFuture

action - действие, чтобы выполнить прежде, чем завершить возвращенный CompletableFuture

Возвраты:

новый CompletableFuture

runAfterBothAsync

public CompletableFuture<Void> runAfterBothAsync(CompletableFuture<?> other,
                                                 Runnable action,
                                                 Executor executor)

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

Если это и/или другой CompletableFuture, полный исключительно, или предоставленное действие, выдают исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

other - другой CompletableFuture

action - действие, чтобы выполнить прежде, чем завершить возвращенный CompletableFuture

executor - исполнитель, чтобы использовать для асинхронного выполнения

Возвраты:

новый CompletableFuture

applyToEither

public <U> CompletableFuture<U> applyToEither(CompletableFuture<? extends T> other,
                                              Function<? super T,U> fn)

Возвращает новый CompletableFuture, который завершается, когда или это или другой данный CompletableFuture завершаются с результатом заданной функции или этого или результата другого CompletableFuture.

Если это и/или другой CompletableFuture, полный исключительно, то возвращенный CompletableFuture может также сделать так с CompletionException, содержащим одно из этих исключений как его причина. Никакие гарантии не делаются, о котором результат или исключение используются в возвращенном CompletableFuture. Если предоставленная функция выдает исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

other - другой CompletableFuture

fn - функция, чтобы использовать, чтобы вычислить значение возвращенного CompletableFuture

Возвраты:

новый CompletableFuture

applyToEitherAsync

public <U> CompletableFuture<U> applyToEitherAsync(CompletableFuture<? extends T> other,
                                                   Function<? super T,U> fn)

Возвращает новый CompletableFuture, который асинхронно завершается, когда или это или другой данный CompletableFuture завершаются с результатом заданной функции или этого или следствия другого CompletableFuture задачи, работающей в ForkJoinPool.commonPool().

Если это и/или другой CompletableFuture, полный исключительно, то возвращенный CompletableFuture может также сделать так с CompletionException, содержащим одно из этих исключений как его причина. Никакие гарантии не делаются, о котором результат или исключение используются в возвращенном CompletableFuture. Если предоставленная функция выдает исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

other - другой CompletableFuture

fn - функция, чтобы использовать, чтобы вычислить значение возвращенного CompletableFuture

Возвраты:

новый CompletableFuture

applyToEitherAsync

public <U> CompletableFuture<U> applyToEitherAsync(CompletableFuture<? extends T> other,
                                                   Function<? super T,U> fn,
                                                   Executor executor)

Возвращает новый CompletableFuture, который асинхронно завершается, когда или это или другой данный CompletableFuture завершаются с результатом заданной функции или этого или следствия другого CompletableFuture задачи, работающей в данном исполнителе.

Если это и/или другой CompletableFuture, полный исключительно, то возвращенный CompletableFuture может также сделать так с CompletionException, содержащим одно из этих исключений как его причина. Никакие гарантии не делаются, о котором результат или исключение используются в возвращенном CompletableFuture. Если предоставленная функция выдает исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

other - другой CompletableFuture

fn - функция, чтобы использовать, чтобы вычислить значение возвращенного CompletableFuture

executor - исполнитель, чтобы использовать для асинхронного выполнения

Возвраты:

новый CompletableFuture

acceptEither

public CompletableFuture<Void> acceptEither(CompletableFuture<? extends T> other,
                                            Consumer<? super T> block)

Возвращает новый CompletableFuture, который завершается, когда или это или другой данный CompletableFuture завершаются после выполнения данного действия с результатом или этого или результата другого CompletableFuture.

Если это и/или другой CompletableFuture, полный исключительно, то возвращенный CompletableFuture может также сделать так с CompletionException, содержащим одно из этих исключений как его причина. Никакие гарантии не делаются, о котором результат или исключение используются в возвращенном CompletableFuture. Если предоставленное действие выдает исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

other - другой CompletableFuture

block - действие, чтобы выполнить прежде, чем завершить возвращенный CompletableFuture

Возвраты:

новый CompletableFuture

acceptEitherAsync

public CompletableFuture<Void> acceptEitherAsync(CompletableFuture<? extends T> other,
                                                 Consumer<? super T> block)

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

Если это и/или другой CompletableFuture, полный исключительно, то возвращенный CompletableFuture может также сделать так с CompletionException, содержащим одно из этих исключений как его причина. Никакие гарантии не делаются, о котором результат или исключение используются в возвращенном CompletableFuture. Если предоставленное действие выдает исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

other - другой CompletableFuture

block - действие, чтобы выполнить прежде, чем завершить возвращенный CompletableFuture

Возвраты:

новый CompletableFuture

acceptEitherAsync

public CompletableFuture<Void> acceptEitherAsync(CompletableFuture<? extends T> other,
                                                 Consumer<? super T> block,
                                                 Executor executor)

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

Если это и/или другой CompletableFuture, полный исключительно, то возвращенный CompletableFuture может также сделать так с CompletionException, содержащим одно из этих исключений как его причина. Никакие гарантии не делаются, о котором результат или исключение используются в возвращенном CompletableFuture. Если предоставленное действие выдает исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

other - другой CompletableFuture

block - действие, чтобы выполнить прежде, чем завершить возвращенный CompletableFuture

executor - исполнитель, чтобы использовать для асинхронного выполнения

Возвраты:

новый CompletableFuture

runAfterEither

public CompletableFuture<Void> runAfterEither(CompletableFuture<?> other,
                                              Runnable action)

Возвращает новый CompletableFuture, который завершается, когда или это или другой данный CompletableFuture завершаются после выполнения данного действия.

Если это и/или другой CompletableFuture, полный исключительно, то возвращенный CompletableFuture может также сделать так с CompletionException, содержащим одно из этих исключений как его причина. Никакие гарантии не делаются, о котором результат или исключение используются в возвращенном CompletableFuture. Если предоставленное действие выдает исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

other - другой CompletableFuture

action - действие, чтобы выполнить прежде, чем завершить возвращенный CompletableFuture

Возвраты:

новый CompletableFuture

runAfterEitherAsync

public CompletableFuture<Void> runAfterEitherAsync(CompletableFuture<?> other,
                                                   Runnable action)

Возвращает новый CompletableFuture, который асинхронно завершается, когда или это или другой данный CompletableFuture завершаются после выполнения данного действия от задачи, работающей в ForkJoinPool.commonPool().

Если это и/или другой CompletableFuture, полный исключительно, то возвращенный CompletableFuture может также сделать так с CompletionException, содержащим одно из этих исключений как его причина. Никакие гарантии не делаются, о котором результат или исключение используются в возвращенном CompletableFuture. Если предоставленное действие выдает исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

other - другой CompletableFuture

action - действие, чтобы выполнить прежде, чем завершить возвращенный CompletableFuture

Возвраты:

новый CompletableFuture

runAfterEitherAsync

public CompletableFuture<Void> runAfterEitherAsync(CompletableFuture<?> other,
                                                   Runnable action,
                                                   Executor executor)

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

Если это и/или другой CompletableFuture, полный исключительно, то возвращенный CompletableFuture может также сделать так с CompletionException, содержащим одно из этих исключений как его причина. Никакие гарантии не делаются, о котором результат или исключение используются в возвращенном CompletableFuture. Если предоставленное действие выдает исключение, то возвращенный CompletableFuture завершается исключительно с CompletionException, содержащим исключение как его причина.

Параметры:

other - другой CompletableFuture

action - действие, чтобы выполнить прежде, чем завершить возвращенный CompletableFuture

executor - исполнитель, чтобы использовать для асинхронного выполнения

Возвраты:

новый CompletableFuture

thenCompose

public <U> CompletableFuture<U> thenCompose(Function<? super T,CompletableFuture<U>> fn)

Возвращает CompletableFuture, что после завершения, имеет то же самое значение как произведено заданной функцией результата этого CompletableFuture.

Если этот CompletableFuture завершается исключительно, то возвращенный CompletableFuture также делает так с CompletionException, содержащим это исключение как его причина. Точно так же, если вычисленный CompletableFuture завершается исключительно, то так делает возвращенный CompletableFuture.

Параметры:

fn - функция, возвращая новый CompletableFuture

Возвраты:

CompletableFuture

thenComposeAsync

public <U> CompletableFuture<U> thenComposeAsync(Function<? super T,CompletableFuture<U>> fn)

Возвращает CompletableFuture, что после завершения, имеет то же самое значение, как это произвело асинхронно использование ForkJoinPool.commonPool() заданной функцией результата этого CompletableFuture.

Если этот CompletableFuture завершается исключительно, то возвращенный CompletableFuture также делает так с CompletionException, содержащим это исключение как его причина. Точно так же, если вычисленный CompletableFuture завершается исключительно, то так делает возвращенный CompletableFuture.

Параметры:

fn - функция, возвращая новый CompletableFuture

Возвраты:

CompletableFuture

thenComposeAsync

public <U> CompletableFuture<U> thenComposeAsync(Function<? super T,CompletableFuture<U>> fn,
                                                 Executor executor)

Возвращает CompletableFuture, что после завершения, имеет то же самое значение, как это произвело асинхронно использование данного исполнителя заданной функцией этого CompletableFuture.

Если этот CompletableFuture завершается исключительно, то возвращенный CompletableFuture также делает так с CompletionException, содержащим это исключение как его причина. Точно так же, если вычисленный CompletableFuture завершается исключительно, то так делает возвращенный CompletableFuture.

Параметры:

fn - функция, возвращая новый CompletableFuture

executor - исполнитель, чтобы использовать для асинхронного выполнения

Возвраты:

CompletableFuture

исключительно

public CompletableFuture<T> exceptionally(Function<Throwable,? extends T> fn)

Возвращает новый CompletableFuture, который завершается, когда этот CompletableFuture завершается с результатом заданной функции исключения, инициировавшего завершение этого CompletableFuture, когда это завершается исключительно; иначе, если этот CompletableFuture обычно завершается, то возвращенный CompletableFuture также обычно завершается с тем же самым значением.

Параметры:

fn - функция, чтобы использовать, чтобы вычислить значение возвращенного CompletableFuture, если этот CompletableFuture, завершенный исключительно

Возвраты:

новый CompletableFuture

дескриптор

public <U> CompletableFuture<U> handle(BiFunction<? super T,Throwable,? extends U> fn)

Возвращает новый CompletableFuture, который завершается, когда этот CompletableFuture завершается с результатом заданной функции результата и исключения завершения этого CompletableFuture. Заданная функция вызывается с результатом (или null если ни один) и исключение (или null если ни один) этого CompletableFuture когда завершено.

Параметры:

fn - функция, чтобы использовать, чтобы вычислить значение возвращенного CompletableFuture

Возвраты:

новый CompletableFuture

allOf

public static CompletableFuture<Void> allOf(CompletableFuture<?>... cfs)

Возвращает новый CompletableFuture, который завершается, когда все данные CompletableFutures завершаются. Если любой из данных CompletableFutures, полных исключительно, то возвращенный CompletableFuture также делает так с CompletionException, содержащим это исключение как его причина. Иначе, результаты, если таковые вообще имеются, данного CompletableFutures не отражаются в возвращенном CompletableFuture, но могут быть получены, осматривая их индивидуально. Если никаким CompletableFutures не предоставляют, возвращает CompletableFuture, завершенный со значением null.

Среди приложений этого метода должен ждать завершения ряда независимого CompletableFutures прежде, чем продолжать программу, как в: CompletableFuture.allOf(c1, c2, c3).join();.

Параметры:

cfs - CompletableFutures

Возвраты:

новый CompletableFuture, который завершается, когда все данные CompletableFutures завершаются

Броски:

NullPointerException - если массив или какой-либо из его элементов null

anyOf

public static CompletableFuture<Object> anyOf(CompletableFuture<?>... cfs)

Возвращает новый CompletableFuture, который завершается когда любой из данных полных CompletableFutures с тем же самым результатом. Иначе, если это завершалось исключительно, возвращенный CompletableFuture также делает так с CompletionException, содержащим это исключение как его причина. Если никаким CompletableFutures не предоставляют, возвращает неполный CompletableFuture.

Параметры:

cfs - CompletableFutures

Возвраты:

новый CompletableFuture, который завершается с результатом или исключением любого из данных CompletableFutures, когда каждый завершается

Броски:

NullPointerException - если массив или какой-либо из его элементов null

отмена

public boolean cancel(boolean mayInterruptIfRunning)

Если не уже завершенный, завершает этот CompletableFuture с a CancellationException. Зависимые CompletableFutures, которые уже не завершились, также завершатся исключительно с a CompletionException вызванный этим CancellationException.

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

cancel в интерфейсе Future<T>

Параметры:

mayInterruptIfRunning - это значение не имеет никакого эффекта в этой реализации, потому что прерывания не используются, чтобы управлять обработкой.

Возвраты:

true если эта задача теперь отменяется

isCancelled

public boolean isCancelled()

Возвраты true если этот CompletableFuture был отменен прежде, чем он обычно завершался.

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

isCancelled в интерфейсе Future<T>

Возвраты:

true если этот CompletableFuture был отменен прежде, чем он обычно завершался

obtrudeValue

public void obtrudeValue(T value)

Насильственно наборы или сбросы значение впоследствии возвратились методом get() и связанные методы, действительно ли уже завершенный. Этот метод разрабатывается для использования только в действиях восстановления после ошибки, и даже в таких ситуациях может привести к продолжающемуся зависимому использованию завершений, установленному против перезаписанных результатов.

Параметры:

value - значение завершения

obtrudeException

public void obtrudeException(Throwable ex)

Насильственно вызывает последующие вызовы метода get() и связанные методы, чтобы выдать данное исключение, действительно ли уже завершенный. Этот метод разрабатывается для использования только в действиях восстановления, и даже в таких ситуациях может привести к продолжающемуся зависимому использованию завершений, установленному против перезаписанных результатов.

Параметры:

ex - исключение

getNumberOfDependents

public int getNumberOfDependents()

Возвращает предполагаемое число CompletableFutures, завершения которого ждут завершения этого CompletableFuture. Этот метод разрабатывается для использования в состоянии системы контроля, не для управления синхронизацией.

Возвраты:

число зависимого CompletableFutures

toString

public String toString()

Возвращает строку, идентифицирующую этот CompletableFuture, так же как его состояние завершения. Состояние, в скобках, содержит Строку "Completed Normally" или Строка "Completed Exceptionally", или Строка "Not completed" сопровождаемый числом CompletableFutures, зависящего от его завершения, если любой.

Переопределения:

toString в class Object

Возвраты:

строка, идентифицирующая этот CompletableFuture, так же как его состояние