private final class CombinedFuture.AsyncCallableInterruptibleTask extends CombinedFuture.CombinedFutureInterruptibleTask<ListenableFuture<V>>
InterruptibleTask.Blocker| Modifier and Type | Field and Description |
|---|---|
private AsyncCallable<V> |
callable |
| Constructor and Description |
|---|
AsyncCallableInterruptibleTask(AsyncCallable<V> callable,
java.util.concurrent.Executor listenerExecutor) |
| Modifier and Type | Method and Description |
|---|---|
(package private) ListenableFuture<V> |
runInterruptibly()
Do interruptible work here - do not complete Futures here, as their listeners could be
interrupted.
|
(package private) void |
setValue(ListenableFuture<V> value) |
(package private) java.lang.String |
toPendingString() |
afterRanInterruptiblyFailure, afterRanInterruptiblySuccess, execute, isDoneinterruptTask, run, toStringprivate final AsyncCallable<V> callable
AsyncCallableInterruptibleTask(AsyncCallable<V> callable, java.util.concurrent.Executor listenerExecutor)
ListenableFuture<V> runInterruptibly() throws java.lang.Exception
InterruptibleTaskrunInterruptibly in class InterruptibleTask<ListenableFuture<V>>java.lang.Exceptionvoid setValue(ListenableFuture<V> value)
setValue in class CombinedFuture.CombinedFutureInterruptibleTask<ListenableFuture<V>>java.lang.String toPendingString()
toPendingString in class InterruptibleTask<ListenableFuture<V>>