com.hazelcast.spi.impl

Class AbstractInvocationFuture<V>

java.lang.Object

java.util.concurrent.CompletableFuture<V>

com.hazelcast.spi.impl.InternalCompletableFuture<V>

com.hazelcast.spi.impl.AbstractInvocationFuture<V>

Type Parameters:

V -

All Implemented Interfaces:

CompletionStage<V>, Future<V>

Direct Known Subclasses:

ClientInvocationFuture, InvocationFuture

public abstract class AbstractInvocationFuture<V>
extends InternalCompletableFuture<V>

Custom implementation of CompletableFuture.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	AbstractInvocationFuture.AbstractBiNode<T,U,R>
protected static class	AbstractInvocationFuture.AbstractEitherNode<T,R>
protected static class	AbstractInvocationFuture.ApplyNode<V,R>
protected static class	AbstractInvocationFuture.ComposeNode<T,U>
protected static class	AbstractInvocationFuture.ExceptionallyNode<R>
static class	AbstractInvocationFuture.ExceptionalResult
protected static class	AbstractInvocationFuture.RunNode

Nested classes/interfaces inherited from class java.util.concurrent.CompletableFuture

CompletableFuture.AsynchronousCompletionTask

Field Summary

Fields

Modifier and Type	Field and Description
protected ILogger	logger
protected Object	state This field contains the state of the future.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractInvocationFuture(ILogger logger)

Method Summary

Modifier and Type	Method and Description
InternalCompletableFuture<Void>	acceptEither(CompletionStage<? extends V> other, Consumer<? super V> action)
InternalCompletableFuture<Void>	acceptEitherAsync(CompletionStage<? extends V> other, Consumer<? super V> action)
InternalCompletableFuture<Void>	acceptEitherAsync(CompletionStage<? extends V> other, Consumer<? super V> action, Executor executor)
<U> InternalCompletableFuture<U>	applyToEither(CompletionStage<? extends V> other, Function<? super V,U> fn)
<U> InternalCompletableFuture<U>	applyToEitherAsync(CompletionStage<? extends V> other, Function<? super V,U> fn)
<U> InternalCompletableFuture<U>	applyToEitherAsync(CompletionStage<? extends V> other, Function<? super V,U> fn, Executor executor)
boolean	cancel(boolean mayInterruptIfRunning)
boolean	complete(Object value) Can be called multiple times, but only the first answer will lead to the future getting triggered.
boolean	completeExceptionally(Throwable ex)
boolean	completeExceptionallyInternal(Object value)
Executor	defaultExecutor()
InternalCompletableFuture<V>	exceptionally(Function<Throwable,? extends V> fn)
V	get()
V	get(long timeout, TimeUnit unit)
V	getNow(V valueIfAbsent)
int	getNumberOfDependents()
protected Object	getState()
<U> InternalCompletableFuture<U>	handle(BiFunction<? super V,Throwable,? extends U> fn)
<U> InternalCompletableFuture<U>	handleAsync(BiFunction<? super V,Throwable,? extends U> fn)
<U> InternalCompletableFuture<U>	handleAsync(BiFunction<? super V,Throwable,? extends U> fn, Executor executor)
protected abstract String	invocationToString()
boolean	isCancelled()
boolean	isCompletedExceptionally()
boolean	isDone()
V	join()
V	joinInternal() Similarly to join(), returns the value when complete or throws an unchecked exception if completed exceptionally.
protected abstract TimeoutException	newTimeoutException(long timeout, TimeUnit unit)
void	obtrudeException(Throwable ex)
void	obtrudeValue(V value)
protected void	onComplete()
protected void	onInterruptDetected()
protected Object	resolve(Object value)
protected abstract V	resolveAndThrowIfException(Object state)
protected V	resolveAndThrowWithJoinConvention(Object state)
protected V	returnOrThrowWithJoinConventions(Object resolved)
InternalCompletableFuture<Void>	runAfterBoth(CompletionStage<?> other, Runnable action)
InternalCompletableFuture<Void>	runAfterBothAsync(CompletionStage<?> other, Runnable action)
InternalCompletableFuture<Void>	runAfterBothAsync(CompletionStage<?> other, Runnable action, Executor executor)
InternalCompletableFuture<Void>	runAfterEither(CompletionStage<?> other, Runnable action)
InternalCompletableFuture<Void>	runAfterEitherAsync(CompletionStage<?> other, Runnable action)
InternalCompletableFuture<Void>	runAfterEitherAsync(CompletionStage<?> other, Runnable action, Executor executor)
InternalCompletableFuture<Void>	thenAccept(Consumer<? super V> action)
InternalCompletableFuture<Void>	thenAcceptAsync(Consumer<? super V> action)
InternalCompletableFuture<Void>	thenAcceptAsync(Consumer<? super V> action, Executor executor)
<U> InternalCompletableFuture<Void>	thenAcceptBoth(CompletionStage<? extends U> other, BiConsumer<? super V,? super U> action)
<U> InternalCompletableFuture<Void>	thenAcceptBothAsync(CompletionStage<? extends U> other, BiConsumer<? super V,? super U> action)
<U> InternalCompletableFuture<Void>	thenAcceptBothAsync(CompletionStage<? extends U> other, BiConsumer<? super V,? super U> action, Executor executor)
<U> InternalCompletableFuture<U>	thenApply(Function<? super V,? extends U> fn)
<U> InternalCompletableFuture<U>	thenApplyAsync(Function<? super V,? extends U> fn)
<U> InternalCompletableFuture<U>	thenApplyAsync(Function<? super V,? extends U> fn, Executor executor)
<U,R> InternalCompletableFuture<R>	thenCombine(CompletionStage<? extends U> other, BiFunction<? super V,? super U,? extends R> fn)
<U,R> InternalCompletableFuture<R>	thenCombineAsync(CompletionStage<? extends U> other, BiFunction<? super V,? super U,? extends R> fn)
<U,R> InternalCompletableFuture<R>	thenCombineAsync(CompletionStage<? extends U> other, BiFunction<? super V,? super U,? extends R> fn, Executor executor)
<U> InternalCompletableFuture<U>	thenCompose(Function<? super V,? extends CompletionStage<U>> fn)
<U> InternalCompletableFuture<U>	thenComposeAsync(Function<? super V,? extends CompletionStage<U>> fn)
<U> InternalCompletableFuture<U>	thenComposeAsync(Function<? super V,? extends CompletionStage<U>> fn, Executor executor)
InternalCompletableFuture<Void>	thenRun(Runnable action)
InternalCompletableFuture<Void>	thenRunAsync(Runnable action)
InternalCompletableFuture<Void>	thenRunAsync(Runnable action, Executor executor)
InternalCompletableFuture<V>	toCompletableFuture()
String	toString()
protected void	unblockAcceptEither(Consumer<? super V> action, Executor executor, CompletableFuture<Void> future)
protected <U> void	unblockApply(Function<? super V,? extends U> function, Executor executor, InternalCompletableFuture<U> future)
protected <U> void	unblockApplyToEither(Function<? super V,U> action, Executor executor, CompletableFuture<U> future)
protected <U,R> void	unblockCombine(CompletionStage<? extends U> other, BiFunction<? super V,? super U,? extends R> function, Executor executor, InternalCompletableFuture<R> future)
protected <U> void	unblockCompose(Function<? super V,? extends CompletionStage<U>> function, Executor executor, CompletableFuture<U> future)
protected <U> void	unblockHandle(BiFunction<? super V,Throwable,? extends U> fn, Executor executor, CompletableFuture<U> future)
protected void	unblockOtherNode(Object waiter, Executor executor)
protected void	unblockRun(Runnable runnable, Executor executor, CompletableFuture<Void> future)
protected CompletableFuture<Void>	unblockRunAfterEither(Runnable action, Executor executor, CompletableFuture<Void> future)
protected void	unblockWhenComplete(BiConsumer<? super V,? super Throwable> biConsumer, Executor executor, CompletableFuture<V> future)
InternalCompletableFuture<V>	whenComplete(BiConsumer<? super V,? super Throwable> action)
InternalCompletableFuture<V>	whenCompleteAsync(BiConsumer<? super V,? super Throwable> action)
InternalCompletableFuture<V>	whenCompleteAsync(BiConsumer<? super V,? super Throwable> action, Executor executor)
protected static AbstractInvocationFuture.ExceptionalResult	wrapThrowable(Object value)
protected abstract Exception	wrapToInstanceNotActiveException(RejectedExecutionException e)

Methods inherited from class com.hazelcast.spi.impl.InternalCompletableFuture

completedExceptionally, completedExceptionally, completingCallback, newCompletedFuture, newCompletedFuture, newCompletedFuture, newCompletedFuture, newDelegatingFuture, withExecutor

Methods inherited from class java.util.concurrent.CompletableFuture

allOf, anyOf, completedFuture, runAsync, runAsync, supplyAsync, supplyAsync

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final ILogger logger

state

protected volatile Object state

This field contains the state of the future. If the future is not complete, the state can be:

1. UNRESOLVED: no response is available.
2. Thread instance: no response is available and a thread has blocked on completion (e.g. future.get)
3. WaitNode or Waiter instance: in case of multiple callback registrations or future.gets.

If the state is anything else, it is completed.

The reason why a single future.get or registered ExecutionCallback doesn't create a WaitNode is that we don't want to cause additional litter since most of our API calls are a get or a single ExecutionCallback.

The state field is replaced using a cas, so registration or setting a response is an atomic operation and therefore not prone to data-races. There is no need to use synchronized blocks.

Constructor Detail

AbstractInvocationFuture

protected AbstractInvocationFuture(@Nonnull
                                   ILogger logger)

Method Detail

invocationToString

protected abstract String invocationToString()

resolveAndThrowIfException

protected abstract V resolveAndThrowIfException(Object state)
                                         throws ExecutionException,
                                                InterruptedException

Throws:

ExecutionException

InterruptedException

newTimeoutException

protected abstract TimeoutException newTimeoutException(long timeout,
                                                        TimeUnit unit)

thenApply

public <U> InternalCompletableFuture<U> thenApply(@Nonnull
                                                  Function<? super V,? extends U> fn)

Specified by:

thenApply in interface CompletionStage<V>

Overrides:

thenApply in class CompletableFuture<V>

thenApplyAsync

public <U> InternalCompletableFuture<U> thenApplyAsync(@Nonnull
                                                       Function<? super V,? extends U> fn)

Specified by:

thenApplyAsync in interface CompletionStage<V>

Overrides:

thenApplyAsync in class CompletableFuture<V>

thenApplyAsync

public <U> InternalCompletableFuture<U> thenApplyAsync(@Nonnull
                                                       Function<? super V,? extends U> fn,
                                                       Executor executor)

Specified by:

thenApplyAsync in interface CompletionStage<V>

Overrides:

thenApplyAsync in class CompletableFuture<V>

thenAccept

public InternalCompletableFuture<Void> thenAccept(@Nonnull
                                                  Consumer<? super V> action)

Specified by:

thenAccept in interface CompletionStage<V>

Overrides:

thenAccept in class CompletableFuture<V>

thenAcceptAsync

public InternalCompletableFuture<Void> thenAcceptAsync(@Nonnull
                                                       Consumer<? super V> action)

Specified by:

thenAcceptAsync in interface CompletionStage<V>

Overrides:

thenAcceptAsync in class CompletableFuture<V>

thenAcceptAsync

public InternalCompletableFuture<Void> thenAcceptAsync(@Nonnull
                                                       Consumer<? super V> action,
                                                       @Nonnull
                                                       Executor executor)

Specified by:

thenAcceptAsync in interface CompletionStage<V>

Overrides:

thenAcceptAsync in class CompletableFuture<V>

thenRun

public InternalCompletableFuture<Void> thenRun(@Nonnull
                                               Runnable action)

Specified by:

thenRun in interface CompletionStage<V>

Overrides:

thenRun in class CompletableFuture<V>

thenRunAsync

public InternalCompletableFuture<Void> thenRunAsync(@Nonnull
                                                    Runnable action)

Specified by:

thenRunAsync in interface CompletionStage<V>

Overrides:

thenRunAsync in class CompletableFuture<V>

thenRunAsync

public InternalCompletableFuture<Void> thenRunAsync(@Nonnull
                                                    Runnable action,
                                                    @Nonnull
                                                    Executor executor)

Specified by:

thenRunAsync in interface CompletionStage<V>

Overrides:

thenRunAsync in class CompletableFuture<V>

handle

public <U> InternalCompletableFuture<U> handle(@Nonnull
                                               BiFunction<? super V,Throwable,? extends U> fn)

Specified by:

handle in interface CompletionStage<V>

Overrides:

handle in class CompletableFuture<V>

handleAsync

public <U> InternalCompletableFuture<U> handleAsync(@Nonnull
                                                    BiFunction<? super V,Throwable,? extends U> fn)

Specified by:

handleAsync in interface CompletionStage<V>

Overrides:

handleAsync in class CompletableFuture<V>

handleAsync

public <U> InternalCompletableFuture<U> handleAsync(@Nonnull
                                                    BiFunction<? super V,Throwable,? extends U> fn,
                                                    @Nonnull
                                                    Executor executor)

Specified by:

handleAsync in interface CompletionStage<V>

Overrides:

handleAsync in class CompletableFuture<V>

whenComplete

public InternalCompletableFuture<V> whenComplete(@Nonnull
                                                 BiConsumer<? super V,? super Throwable> action)

Specified by:

whenComplete in interface CompletionStage<V>

Overrides:

whenComplete in class CompletableFuture<V>

whenCompleteAsync

public InternalCompletableFuture<V> whenCompleteAsync(@Nonnull
                                                      BiConsumer<? super V,? super Throwable> action)

Specified by:

whenCompleteAsync in interface CompletionStage<V>

Overrides:

whenCompleteAsync in class CompletableFuture<V>

whenCompleteAsync

public InternalCompletableFuture<V> whenCompleteAsync(@Nonnull
                                                      BiConsumer<? super V,? super Throwable> action,
                                                      @Nonnull
                                                      Executor executor)

Specified by:

whenCompleteAsync in interface CompletionStage<V>

Overrides:

whenCompleteAsync in class CompletableFuture<V>

thenCompose

public <U> InternalCompletableFuture<U> thenCompose(@Nonnull
                                                    Function<? super V,? extends CompletionStage<U>> fn)

Specified by:

thenCompose in interface CompletionStage<V>

Overrides:

thenCompose in class CompletableFuture<V>

thenComposeAsync

public <U> InternalCompletableFuture<U> thenComposeAsync(@Nonnull
                                                         Function<? super V,? extends CompletionStage<U>> fn)

Specified by:

thenComposeAsync in interface CompletionStage<V>

Overrides:

thenComposeAsync in class CompletableFuture<V>

thenComposeAsync

public <U> InternalCompletableFuture<U> thenComposeAsync(@Nonnull
                                                         Function<? super V,? extends CompletionStage<U>> fn,
                                                         @Nonnull
                                                         Executor executor)

Specified by:

thenComposeAsync in interface CompletionStage<V>

Overrides:

thenComposeAsync in class CompletableFuture<V>

thenCombine

public <U,R> InternalCompletableFuture<R> thenCombine(@Nonnull
                                                      CompletionStage<? extends U> other,
                                                      @Nonnull
                                                      BiFunction<? super V,? super U,? extends R> fn)

Specified by:

thenCombine in interface CompletionStage<V>

Overrides:

thenCombine in class CompletableFuture<V>

thenCombineAsync

public <U,R> InternalCompletableFuture<R> thenCombineAsync(@Nonnull
                                                           CompletionStage<? extends U> other,
                                                           @Nonnull
                                                           BiFunction<? super V,? super U,? extends R> fn)

Specified by:

thenCombineAsync in interface CompletionStage<V>

Overrides:

thenCombineAsync in class CompletableFuture<V>

thenCombineAsync

public <U,R> InternalCompletableFuture<R> thenCombineAsync(@Nonnull
                                                           CompletionStage<? extends U> other,
                                                           @Nonnull
                                                           BiFunction<? super V,? super U,? extends R> fn,
                                                           @Nonnull
                                                           Executor executor)

Specified by:

thenCombineAsync in interface CompletionStage<V>

Overrides:

thenCombineAsync in class CompletableFuture<V>

thenAcceptBoth

public <U> InternalCompletableFuture<Void> thenAcceptBoth(@Nonnull
                                                          CompletionStage<? extends U> other,
                                                          @Nonnull
                                                          BiConsumer<? super V,? super U> action)

Specified by:

thenAcceptBoth in interface CompletionStage<V>

Overrides:

thenAcceptBoth in class CompletableFuture<V>

thenAcceptBothAsync

public <U> InternalCompletableFuture<Void> thenAcceptBothAsync(@Nonnull
                                                               CompletionStage<? extends U> other,
                                                               @Nonnull
                                                               BiConsumer<? super V,? super U> action)

Specified by:

thenAcceptBothAsync in interface CompletionStage<V>

Overrides:

thenAcceptBothAsync in class CompletableFuture<V>

thenAcceptBothAsync

public <U> InternalCompletableFuture<Void> thenAcceptBothAsync(@Nonnull
                                                               CompletionStage<? extends U> other,
                                                               @Nonnull
                                                               BiConsumer<? super V,? super U> action,
                                                               @Nonnull
                                                               Executor executor)

Specified by:

thenAcceptBothAsync in interface CompletionStage<V>

Overrides:

thenAcceptBothAsync in class CompletableFuture<V>

runAfterBoth

public InternalCompletableFuture<Void> runAfterBoth(@Nonnull
                                                    CompletionStage<?> other,
                                                    @Nonnull
                                                    Runnable action)

Specified by:

runAfterBoth in interface CompletionStage<V>

Overrides:

runAfterBoth in class CompletableFuture<V>

runAfterBothAsync

public InternalCompletableFuture<Void> runAfterBothAsync(@Nonnull
                                                         CompletionStage<?> other,
                                                         @Nonnull
                                                         Runnable action)

Specified by:

runAfterBothAsync in interface CompletionStage<V>

Overrides:

runAfterBothAsync in class CompletableFuture<V>

runAfterBothAsync

public InternalCompletableFuture<Void> runAfterBothAsync(@Nonnull
                                                         CompletionStage<?> other,
                                                         @Nonnull
                                                         Runnable action,
                                                         @Nonnull
                                                         Executor executor)

Specified by:

runAfterBothAsync in interface CompletionStage<V>

Overrides:

runAfterBothAsync in class CompletableFuture<V>

applyToEither

public <U> InternalCompletableFuture<U> applyToEither(@Nonnull
                                                      CompletionStage<? extends V> other,
                                                      @Nonnull
                                                      Function<? super V,U> fn)

Specified by:

applyToEither in interface CompletionStage<V>

Overrides:

applyToEither in class CompletableFuture<V>

applyToEitherAsync

public <U> InternalCompletableFuture<U> applyToEitherAsync(@Nonnull
                                                           CompletionStage<? extends V> other,
                                                           @Nonnull
                                                           Function<? super V,U> fn)

Specified by:

applyToEitherAsync in interface CompletionStage<V>

Overrides:

applyToEitherAsync in class CompletableFuture<V>

applyToEitherAsync

public <U> InternalCompletableFuture<U> applyToEitherAsync(@Nonnull
                                                           CompletionStage<? extends V> other,
                                                           @Nonnull
                                                           Function<? super V,U> fn,
                                                           @Nonnull
                                                           Executor executor)

Specified by:

applyToEitherAsync in interface CompletionStage<V>

Overrides:

applyToEitherAsync in class CompletableFuture<V>

acceptEither

public InternalCompletableFuture<Void> acceptEither(@Nonnull
                                                    CompletionStage<? extends V> other,
                                                    @Nonnull
                                                    Consumer<? super V> action)

Specified by:

acceptEither in interface CompletionStage<V>

Overrides:

acceptEither in class CompletableFuture<V>

acceptEitherAsync

public InternalCompletableFuture<Void> acceptEitherAsync(@Nonnull
                                                         CompletionStage<? extends V> other,
                                                         @Nonnull
                                                         Consumer<? super V> action)

Specified by:

acceptEitherAsync in interface CompletionStage<V>

Overrides:

acceptEitherAsync in class CompletableFuture<V>

acceptEitherAsync

public InternalCompletableFuture<Void> acceptEitherAsync(@Nonnull
                                                         CompletionStage<? extends V> other,
                                                         @Nonnull
                                                         Consumer<? super V> action,
                                                         @Nonnull
                                                         Executor executor)

Specified by:

acceptEitherAsync in interface CompletionStage<V>

Overrides:

acceptEitherAsync in class CompletableFuture<V>

runAfterEither

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

Specified by:

runAfterEither in interface CompletionStage<V>

Overrides:

runAfterEither in class CompletableFuture<V>

runAfterEitherAsync

public InternalCompletableFuture<Void> runAfterEitherAsync(@Nonnull
                                                           CompletionStage<?> other,
                                                           @Nonnull
                                                           Runnable action)

Specified by:

runAfterEitherAsync in interface CompletionStage<V>

Overrides:

runAfterEitherAsync in class CompletableFuture<V>

runAfterEitherAsync

public InternalCompletableFuture<Void> runAfterEitherAsync(@Nonnull
                                                           CompletionStage<?> other,
                                                           @Nonnull
                                                           Runnable action,
                                                           @Nonnull
                                                           Executor executor)

Specified by:

runAfterEitherAsync in interface CompletionStage<V>

Overrides:

runAfterEitherAsync in class CompletableFuture<V>

toCompletableFuture

public InternalCompletableFuture<V> toCompletableFuture()

Specified by:

toCompletableFuture in interface CompletionStage<V>

Overrides:

toCompletableFuture in class CompletableFuture<V>

getState

protected final Object getState()

isDone

public final boolean isDone()

Specified by:

isDone in interface Future<V>

Overrides:

isDone in class CompletableFuture<V>

onInterruptDetected

protected void onInterruptDetected()

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<V>

Overrides:

cancel in class CompletableFuture<V>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<V>

Overrides:

isCancelled in class CompletableFuture<V>

isCompletedExceptionally

public boolean isCompletedExceptionally()

Overrides:

isCompletedExceptionally in class CompletableFuture<V>

join

public final V join()

Overrides:

join in class CompletableFuture<V>

joinInternal

public V joinInternal()

Similarly to join(), returns the value when complete or throws an unchecked exception if completed exceptionally. Unlike join(), checked exceptions are not wrapped in CompletionException; rather they are wrapped in HazelcastExceptions.

Overrides:

joinInternal in class InternalCompletableFuture<V>

Returns:

the result

get

public final V get()
            throws InterruptedException,
                   ExecutionException

Specified by:

get in interface Future<V>

Overrides:

get in class CompletableFuture<V>

Throws:

InterruptedException

ExecutionException

get

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

Specified by:

get in interface Future<V>

Overrides:

get in class CompletableFuture<V>

Throws:

InterruptedException

ExecutionException

TimeoutException

getNow

public V getNow(V valueIfAbsent)

Overrides:

getNow in class CompletableFuture<V>

completeExceptionally

public boolean completeExceptionally(Throwable ex)

Overrides:

completeExceptionally in class CompletableFuture<V>

obtrudeValue

public void obtrudeValue(V value)

Overrides:

obtrudeValue in class CompletableFuture<V>

obtrudeException

public void obtrudeException(Throwable ex)

Overrides:

obtrudeException in class CompletableFuture<V>

getNumberOfDependents

public int getNumberOfDependents()

Overrides:

getNumberOfDependents in class CompletableFuture<V>

unblockOtherNode

protected void unblockOtherNode(Object waiter,
                                Executor executor)

Parameters:

waiter - the current wait node, see javadoc of state field

executor - the Executor on which to execute the action associated with waiter

wrapToInstanceNotActiveException

protected abstract Exception wrapToInstanceNotActiveException(RejectedExecutionException e)

returnOrThrowWithJoinConventions

protected V returnOrThrowWithJoinConventions(Object resolved)

resolve

protected Object resolve(Object value)

Parameters:

value - the resolved state of this future

Returns:

an AbstractInvocationFuture.ExceptionalResult wrapping a Throwable in case value is resolved to an exception, or the normal completion value. Subclasses may choose to treat specific normal completion values in a special way (eg deserialize when the completion value is an instance of Data.

resolveAndThrowWithJoinConvention

protected V resolveAndThrowWithJoinConvention(Object state)

unblockApply

protected <U> void unblockApply(@Nonnull
                                Function<? super V,? extends U> function,
                                @Nonnull
                                Executor executor,
                                @Nonnull
                                InternalCompletableFuture<U> future)

unblockRun

protected void unblockRun(@Nonnull
                          Runnable runnable,
                          @Nonnull
                          Executor executor,
                          @Nonnull
                          CompletableFuture<Void> future)

unblockHandle

protected <U> void unblockHandle(@Nonnull
                                 BiFunction<? super V,Throwable,? extends U> fn,
                                 @Nonnull
                                 Executor executor,
                                 @Nonnull
                                 CompletableFuture<U> future)

unblockWhenComplete

protected void unblockWhenComplete(@Nonnull
                                   BiConsumer<? super V,? super Throwable> biConsumer,
                                   @Nonnull
                                   Executor executor,
                                   @Nonnull
                                   CompletableFuture<V> future)

exceptionally

public InternalCompletableFuture<V> exceptionally(@Nonnull
                                                  Function<Throwable,? extends V> fn)

Specified by:

exceptionally in interface CompletionStage<V>

Overrides:

exceptionally in class CompletableFuture<V>

defaultExecutor

public Executor defaultExecutor()

unblockCompose

protected <U> void unblockCompose(@Nonnull
                                  Function<? super V,? extends CompletionStage<U>> function,
                                  @Nonnull
                                  Executor executor,
                                  @Nonnull
                                  CompletableFuture<U> future)

unblockCombine

protected <U,R> void unblockCombine(@Nonnull
                                    CompletionStage<? extends U> other,
                                    @Nonnull
                                    BiFunction<? super V,? super U,? extends R> function,
                                    @Nonnull
                                    Executor executor,
                                    @Nonnull
                                    InternalCompletableFuture<R> future)

unblockApplyToEither

protected <U> void unblockApplyToEither(@Nonnull
                                        Function<? super V,U> action,
                                        @Nonnull
                                        Executor executor,
                                        @Nonnull
                                        CompletableFuture<U> future)

unblockAcceptEither

protected void unblockAcceptEither(@Nonnull
                                   Consumer<? super V> action,
                                   @Nonnull
                                   Executor executor,
                                   @Nonnull
                                   CompletableFuture<Void> future)

unblockRunAfterEither

protected CompletableFuture<Void> unblockRunAfterEither(@Nonnull
                                                        Runnable action,
                                                        @Nonnull
                                                        Executor executor,
                                                        @Nonnull
                                                        CompletableFuture<Void> future)

complete

public final boolean complete(Object value)

Can be called multiple times, but only the first answer will lead to the future getting triggered. All subsequent complete calls are ignored.

Overrides:

complete in class CompletableFuture<V>

Parameters:

value - The type of response to offer.

Returns:

true if offered response, either a final response or an internal response, is set/applied, false otherwise. If false is returned, that means offered response is ignored because a final response is already set to this future.

completeExceptionallyInternal

public final boolean completeExceptionallyInternal(Object value)

onComplete

protected void onComplete()

toString

public String toString()

Overrides:

toString in class CompletableFuture<V>

wrapThrowable

protected static AbstractInvocationFuture.ExceptionalResult wrapThrowable(Object value)