private final class TrustedListenableFutureTask.TrustedFutureInterruptibleTask extends InterruptibleTask<V>
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.Callable<V> |
callable |
Constructor and Description |
---|
TrustedFutureInterruptibleTask(java.util.concurrent.Callable<V> callable) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
afterRanInterruptibly(V result,
java.lang.Throwable error)
Any interruption that happens as a result of calling interruptTask will arrive before this
method is called.
|
(package private) boolean |
isDone()
Called before runInterruptibly - if true, runInterruptibly and afterRanInterruptibly will not
be called.
|
(package private) V |
runInterruptibly()
Do interruptible work here - do not complete Futures here, as their listeners could be
interrupted.
|
(package private) java.lang.String |
toPendingString() |
interruptTask, run, toString
private final java.util.concurrent.Callable<V> callable
TrustedFutureInterruptibleTask(java.util.concurrent.Callable<V> callable)
final boolean isDone()
InterruptibleTask
isDone
in class InterruptibleTask<V>
V runInterruptibly() throws java.lang.Exception
InterruptibleTask
runInterruptibly
in class InterruptibleTask<V>
java.lang.Exception
void afterRanInterruptibly(V result, java.lang.Throwable error)
InterruptibleTask
afterRanInterruptibly
in class InterruptibleTask<V>
java.lang.String toPendingString()
toPendingString
in class InterruptibleTask<V>