E
- public final class InvocationFuture<E> extends AbstractInvocationFuture<E>
InternalCompletableFuture
that waits on the completion
of an Invocation
. The Invocation executes an operation.
In the past the InvocationFuture.get logic was also responsible for detecting the heartbeat for blocking operations
using the CONTINUE_WAIT and detecting if an operation is still running using the IsStillRunning functionality. This
has been removed from the future and moved into the InvocationMonitor
.
AbstractInvocationFuture.AbstractBiNode<T,U,R>, AbstractInvocationFuture.AbstractEitherNode<T,R>, AbstractInvocationFuture.ApplyNode<V,R>, AbstractInvocationFuture.ComposeNode<T,U>, AbstractInvocationFuture.ExceptionallyNode<R>, AbstractInvocationFuture.ExceptionalResult, AbstractInvocationFuture.RunNode
CompletableFuture.AsynchronousCompletionTask
logger, state
Modifier and Type | Method and Description |
---|---|
protected String |
invocationToString() |
boolean |
isCompletedExceptionally() |
protected TimeoutException |
newTimeoutException(long timeout,
TimeUnit unit) |
protected void |
onInterruptDetected() |
protected Object |
resolve(Object unresolved) |
protected E |
resolveAndThrowIfException(Object unresolved) |
static <T> T |
returnOrThrowWithGetConventions(Object resolved) |
protected Exception |
wrapToInstanceNotActiveException(RejectedExecutionException e) |
acceptEither, acceptEitherAsync, acceptEitherAsync, applyToEither, applyToEitherAsync, applyToEitherAsync, cancel, complete, completeExceptionally, completeExceptionallyInternal, defaultExecutor, exceptionally, get, get, getNow, getNumberOfDependents, getState, handle, handleAsync, handleAsync, isCancelled, isDone, join, joinInternal, obtrudeException, obtrudeValue, onComplete, resolveAndThrowWithJoinConvention, returnOrThrowWithJoinConventions, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, thenAccept, thenAcceptAsync, thenAcceptAsync, thenAcceptBoth, thenAcceptBothAsync, thenAcceptBothAsync, thenApply, thenApplyAsync, thenApplyAsync, thenCombine, thenCombineAsync, thenCombineAsync, thenCompose, thenComposeAsync, thenComposeAsync, thenRun, thenRunAsync, thenRunAsync, toCompletableFuture, toString, unblockAcceptEither, unblockApply, unblockApplyToEither, unblockCombine, unblockCompose, unblockHandle, unblockOtherNode, unblockRun, unblockRunAfterEither, unblockWhenComplete, whenComplete, whenCompleteAsync, whenCompleteAsync, wrapThrowable
completedExceptionally, completedExceptionally, completingCallback, newCompletedFuture, newCompletedFuture, newCompletedFuture, newCompletedFuture, newDelegatingFuture, withExecutor
allOf, anyOf, completedFuture, runAsync, runAsync, supplyAsync, supplyAsync
protected void onInterruptDetected()
onInterruptDetected
in class AbstractInvocationFuture<E>
public boolean isCompletedExceptionally()
isCompletedExceptionally
in class AbstractInvocationFuture<E>
protected String invocationToString()
invocationToString
in class AbstractInvocationFuture<E>
protected TimeoutException newTimeoutException(long timeout, TimeUnit unit)
newTimeoutException
in class AbstractInvocationFuture<E>
protected Exception wrapToInstanceNotActiveException(RejectedExecutionException e)
wrapToInstanceNotActiveException
in class AbstractInvocationFuture<E>
protected E resolveAndThrowIfException(Object unresolved) throws ExecutionException, InterruptedException
resolveAndThrowIfException
in class AbstractInvocationFuture<E>
ExecutionException
InterruptedException
public static <T> T returnOrThrowWithGetConventions(Object resolved) throws ExecutionException, InterruptedException
protected Object resolve(Object unresolved)
resolve
in class AbstractInvocationFuture<E>
unresolved
- the resolved state of this futureAbstractInvocationFuture.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
.Copyright © 2019 Hazelcast, Inc.. All rights reserved.