private final class CombinedFuture.CallableInterruptibleTask extends CombinedFuture.CombinedFutureInterruptibleTask<V>
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.Callable<V> |
callable |
thrownByExecute
Constructor and Description |
---|
CallableInterruptibleTask(java.util.concurrent.Callable<V> callable,
java.util.concurrent.Executor listenerExecutor) |
Modifier and Type | Method and Description |
---|---|
(package private) V |
runInterruptibly()
Do interruptible work here - do not complete Futures here, as their listeners could be
interrupted.
|
(package private) void |
setValue(V value) |
(package private) java.lang.String |
toPendingString() |
afterRanInterruptibly, execute, isDone
interruptTask, run, toString
private final java.util.concurrent.Callable<V> callable
public CallableInterruptibleTask(java.util.concurrent.Callable<V> callable, java.util.concurrent.Executor listenerExecutor)
V runInterruptibly() throws java.lang.Exception
InterruptibleTask
runInterruptibly
in class InterruptibleTask<V>
java.lang.Exception
void setValue(V value)
setValue
in class CombinedFuture.CombinedFutureInterruptibleTask<V>
java.lang.String toPendingString()
toPendingString
in class InterruptibleTask<V>