Class CombinedFuture.CombinedFutureInterruptibleTask<T>
java.lang.Object
java.util.concurrent.atomic.AtomicReference<Runnable>
com.google.common.util.concurrent.InterruptibleTask<T>
com.google.common.util.concurrent.CombinedFuture.CombinedFutureInterruptibleTask<T>
- All Implemented Interfaces:
Serializable,Runnable
- Direct Known Subclasses:
CombinedFuture.AsyncCallableInterruptibleTask,CombinedFuture.CallableInterruptibleTask
- Enclosing class:
- CombinedFuture<V>
private abstract class CombinedFuture.CombinedFutureInterruptibleTask<T>
extends InterruptibleTask<T>
-
Nested Class Summary
Nested classes/interfaces inherited from class com.google.common.util.concurrent.InterruptibleTask
InterruptibleTask.Blocker -
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescription(package private) final voidAny interruption that happens as a result of calling interruptTask will arrive before this method is called.(package private) final voidafterRanInterruptiblySuccess(T result) Any interruption that happens as a result of calling interruptTask will arrive before this method is called.(package private) final voidexecute()(package private) final booleanisDone()Called before runInterruptibly - if true, runInterruptibly and afterRanInterruptibly will not be called.(package private) abstract voidMethods inherited from class com.google.common.util.concurrent.InterruptibleTask
interruptTask, run, runInterruptibly, toPendingString, toStringMethods inherited from class java.util.concurrent.atomic.AtomicReference
accumulateAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, get, getAcquire, getAndAccumulate, getAndSet, getAndUpdate, getOpaque, getPlain, lazySet, set, setOpaque, setPlain, setRelease, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
-
Field Details
-
listenerExecutor
-
-
Constructor Details
-
CombinedFutureInterruptibleTask
CombinedFutureInterruptibleTask(Executor listenerExecutor)
-
-
Method Details
-
isDone
final boolean isDone()Description copied from class:InterruptibleTaskCalled before runInterruptibly - if true, runInterruptibly and afterRanInterruptibly will not be called.- Specified by:
isDonein classInterruptibleTask<T>
-
execute
final void execute() -
afterRanInterruptiblySuccess
Description copied from class:InterruptibleTaskAny interruption that happens as a result of calling interruptTask will arrive before this method is called. Complete Futures here.- Specified by:
afterRanInterruptiblySuccessin classInterruptibleTask<T>
-
afterRanInterruptiblyFailure
Description copied from class:InterruptibleTaskAny interruption that happens as a result of calling interruptTask will arrive before this method is called. Complete Futures here.- Specified by:
afterRanInterruptiblyFailurein classInterruptibleTask<T>
-
setValue
-