Class CombinedFuture.CombinedFutureInterruptibleTask<T>
- java.lang.Object
-
- java.util.concurrent.atomic.AtomicReference<java.lang.Runnable>
-
- com.google.common.util.concurrent.InterruptibleTask<T>
-
- com.google.common.util.concurrent.CombinedFuture.CombinedFutureInterruptibleTask<T>
-
- All Implemented Interfaces:
java.io.Serializable
,java.lang.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 Modifier and Type Field Description private java.util.concurrent.Executor
listenerExecutor
-
Constructor Summary
Constructors Constructor Description CombinedFutureInterruptibleTask(java.util.concurrent.Executor listenerExecutor)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description (package private) void
afterRanInterruptiblyFailure(java.lang.Throwable error)
Any interruption that happens as a result of calling interruptTask will arrive before this method is called.(package private) void
afterRanInterruptiblySuccess(T result)
Any interruption that happens as a result of calling interruptTask will arrive before this method is called.(package private) void
execute()
(package private) boolean
isDone()
Called before runInterruptibly - if true, runInterruptibly and afterRanInterruptibly will not be called.(package private) abstract void
setValue(T value)
-
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
-
-
-
-
Method Detail
-
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
final void afterRanInterruptiblySuccess(T result)
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
final void afterRanInterruptiblyFailure(java.lang.Throwable error)
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
abstract void setValue(T value)
-
-