Class CombinedFuture.AsyncCallableInterruptibleTask
java.lang.Object
java.util.concurrent.atomic.AtomicReference<Runnable>
com.google.common.util.concurrent.InterruptibleTask<ListenableFuture<V>>
CombinedFuture<V>.com.google.common.util.concurrent.CombinedFuture.CombinedFutureInterruptibleTask<ListenableFuture<V>>
com.google.common.util.concurrent.CombinedFuture.AsyncCallableInterruptibleTask
- All Implemented Interfaces:
Serializable
,Runnable
- Enclosing class:
CombinedFuture<V>
private final class CombinedFuture.AsyncCallableInterruptibleTask
extends CombinedFuture<V>.CombinedFutureInterruptibleTask<ListenableFuture<V>>
-
Nested Class Summary
Nested classes/interfaces inherited from class com.google.common.util.concurrent.InterruptibleTask
InterruptibleTask.Blocker
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionAsyncCallableInterruptibleTask
(AsyncCallable<V> callable, Executor listenerExecutor) -
Method Summary
Modifier and TypeMethodDescription(package private) ListenableFuture
<V> Do interruptible work here - do not complete Futures here, as their listeners could be interrupted.(package private) void
setValue
(ListenableFuture<V> value) (package private) String
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
-
AsyncCallableInterruptibleTask
AsyncCallableInterruptibleTask(AsyncCallable<V> callable, Executor listenerExecutor)
-
-
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<ListenableFuture<V>>
- Throws:
Exception
-
setValue
- Specified by:
setValue
in classCombinedFuture<V>.CombinedFutureInterruptibleTask<ListenableFuture<V>>
-
toPendingString
String toPendingString()- Specified by:
toPendingString
in classInterruptibleTask<ListenableFuture<V>>
-