private abstract class CombinedFuture.CombinedFutureInterruptibleTask<T> extends InterruptibleTask<T>
InterruptibleTask.Blocker
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.Executor |
listenerExecutor |
Constructor and Description |
---|
CombinedFutureInterruptibleTask(java.util.concurrent.Executor listenerExecutor) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
afterRanInterruptiblyFailure(java.lang.Throwable error)
Any interruption that happens as a result of calling interruptTask will arrive before this
method is called.
|
(package private) void |
afterRanInterruptiblySuccess(T result)
Any interruption that happens as a result of calling interruptTask will arrive before this
method is called.
|
(package private) void |
execute() |
(package private) boolean |
isDone()
Called before runInterruptibly - if true, runInterruptibly and afterRanInterruptibly will not
be called.
|
(package private) abstract void |
setValue(T value) |
interruptTask, run, runInterruptibly, toPendingString, toString
CombinedFutureInterruptibleTask(java.util.concurrent.Executor listenerExecutor)
final boolean isDone()
InterruptibleTask
isDone
in class InterruptibleTask<T>
final void execute()
final void afterRanInterruptiblySuccess(T result)
InterruptibleTask
afterRanInterruptiblySuccess
in class InterruptibleTask<T>
final void afterRanInterruptiblyFailure(java.lang.Throwable error)
InterruptibleTask
afterRanInterruptiblyFailure
in class InterruptibleTask<T>
abstract void setValue(T value)