Class CombinedFuture.AsyncCallableInterruptibleTask
java.lang.Object
java.util.concurrent.atomic.AtomicReference<Runnable>
com.google.common.util.concurrent.InterruptibleTask<T>
CombinedFuture<V>.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) voidsetValue(ListenableFuture<V> value) (package private) StringMethods inherited from class com.google.common.util.concurrent.CombinedFuture.CombinedFutureInterruptibleTask
afterRanInterruptiblyFailure, afterRanInterruptiblySuccess, execute, isDoneMethods inherited from class com.google.common.util.concurrent.InterruptibleTask
interruptTask, run, 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
-
callable
-
-
Constructor Details
-
AsyncCallableInterruptibleTask
AsyncCallableInterruptibleTask(AsyncCallable<V> callable, Executor listenerExecutor)
-
-
Method Details
-
runInterruptibly
Description copied from class:InterruptibleTaskDo interruptible work here - do not complete Futures here, as their listeners could be interrupted.- Specified by:
runInterruptiblyin classInterruptibleTask<ListenableFuture<V>>- Throws:
Exception
-
setValue
- Specified by:
setValuein classCombinedFuture<V>.CombinedFutureInterruptibleTask<ListenableFuture<V>>
-
toPendingString
String toPendingString()- Specified by:
toPendingStringin classInterruptibleTask<ListenableFuture<V>>
-