Class CombinedFuture.CallableInterruptibleTask
java.lang.Object
java.util.concurrent.atomic.AtomicReference<Runnable>
com.google.common.util.concurrent.InterruptibleTask<V>
CombinedFuture<V>.com.google.common.util.concurrent.CombinedFuture.CombinedFutureInterruptibleTask<V>
com.google.common.util.concurrent.CombinedFuture.CallableInterruptibleTask
- All Implemented Interfaces:
Serializable
,Runnable
- Enclosing class:
CombinedFuture<V>
private final class CombinedFuture.CallableInterruptibleTask
extends CombinedFuture<V>.CombinedFutureInterruptibleTask<V>
-
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
Methods inherited from class com.google.common.util.concurrent.CombinedFuture.CombinedFutureInterruptibleTask
afterRanInterruptiblyFailure, afterRanInterruptiblySuccess, execute, isDone
Methods inherited from class com.google.common.util.concurrent.InterruptibleTask
interruptTask, run, 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
-
callable
-
-
Constructor Details
-
CallableInterruptibleTask
-
-
Method Details
-
runInterruptibly
Description copied from class:InterruptibleTask
Do interruptible work here - do not complete Futures here, as their listeners could be interrupted.- Specified by:
runInterruptibly
in classInterruptibleTask<V>
- Throws:
Exception
-
setValue
- Specified by:
setValue
in classCombinedFuture<V>.CombinedFutureInterruptibleTask<V>
-
toPendingString
String toPendingString()- Specified by:
toPendingString
in classInterruptibleTask<V>
-