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 void
Any interruption that happens as a result of calling interruptTask will arrive before this method is called.(package private) final void
afterRanInterruptiblySuccess
(T result) Any interruption that happens as a result of calling interruptTask will arrive before this method is called.(package private) final void
execute()
(package private) final boolean
isDone()
Called before runInterruptibly - if true, runInterruptibly and afterRanInterruptibly will not be called.(package private) abstract void
Methods inherited from class com.google.common.util.concurrent.InterruptibleTask
interruptTask, run, runInterruptibly, toPendingString, toString
Methods 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:InterruptibleTask
Called before runInterruptibly - if true, runInterruptibly and afterRanInterruptibly will not be called.- Specified by:
isDone
in classInterruptibleTask<T>
-
execute
final void execute() -
afterRanInterruptiblySuccess
Description copied from class:InterruptibleTask
Any interruption that happens as a result of calling interruptTask will arrive before this method is called. Complete Futures here.- Specified by:
afterRanInterruptiblySuccess
in classInterruptibleTask<T>
-
afterRanInterruptiblyFailure
Description copied from class:InterruptibleTask
Any interruption that happens as a result of calling interruptTask will arrive before this method is called. Complete Futures here.- Specified by:
afterRanInterruptiblyFailure
in classInterruptibleTask<T>
-
setValue
-