Класс CompletableFuture<T>

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

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

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

Помимо этих и связанных с ними методов для прямого управления состоянием и результатами, CompletableFuture реализует интерфейс CompletionStage со следующими политиками:

• Действия, указанные для зависимых завершений методов без асинхронности, могут выполняться потоком, который завершает текущий CompletableFuture, или любым другим вызывающим методом завершения.
• Все методы асинхронности без явного аргумента Executor выполняются с помощью ForkJoinPool.commonPool() (если он не поддерживает уровень параллелизма не менее двух, в этом случае новый поток создаётся для выполнения каждой задачи). Это может быть переопределено для нестатических методов в подклассах путём определения метода defaultExecutor(). Для упрощения мониторинга, отладки и отслеживания все созданные асинхронные задачи являются экземплярами интерфейса маркера CompletableFuture.AsynchronousCompletionTask. Операции с задержками во времени могут использовать адаптерные методы, определённые в этом классе, например: supplyAsync(supplier, delayedExecutor(timeout, timeUnit)). Для поддержки методов с задержками и таймаутами этот класс поддерживает не более одного демона-потока для запуска и отмены действий, но не для их выполнения.
• Все методы CompletionStage реализуются независимо от других общедоступных методов, поэтому поведение одного метода не изменяется из-за переопределений других в подклассах.
• Все методы CompletionStage возвращают CompletableFutures. Для ограничения использования только методами, определёнными в интерфейсе CompletionStage, используйте метод minimalCompletionStage(). Или для обеспечения того, чтобы клиенты сами не изменяли будущее, используйте метод copy().

CompletableFuture также реализует Future со следующими политиками:

• Поскольку (в отличие от FutureTask) этот класс не имеет прямого контроля над вычислением, которое приводит к его завершению, отмена обрабатывается как просто ещё один вид исключительного завершения. Метод cancel имеет тот же эффект, что и completeExceptionally(new CancellationException()). Метод isCompletedExceptionally() можно использовать для определения, завершился ли CompletableFuture каким-либо исключительным образом.
• В случае исключительного завершения с CompletionException методы get() и get(long, TimeUnit) выбрасывают ExecutionException с той же причиной, что и в соответствующем CompletionException. Для упрощения использования в большинстве случаев этот класс также определяет методы join() и getNow(T), которые вместо этого напрямую выбрасывают CompletionException в этих случаях.

Аргументы, используемые для передачи результата завершения (то есть, для параметров типа T) для методов, принимающих их, могут быть null, но передача null в качестве любого другого параметра приведёт к выбросу NullPointerException.

Подклассы этого класса обычно должны переопределять метод «виртуального конструктора» newIncompleteFuture(), который устанавливает конкретный тип, возвращаемый методами CompletionStage. Например, вот класс, который подставляет другой стандартный Executor и отключает методы obtrude:

class MyCompletableFuture<T> extends CompletableFuture<T> {
   static final Executor myExecutor = ...;
   public MyCompletableFuture() { }
   public <U> CompletableFuture<U> newIncompleteFuture() {
     return new MyCompletableFuture<U>(); }
   public Executor defaultExecutor() {
     return myExecutor; }
   public void obtrudeValue(T value) {
     throw new UnsupportedOperationException(); }
   public void obtrudeException(Throwable ex) {
     throw new UnsupportedOperationException(); }
 }