private final class TrustedListenableFutureTask.TrustedFutureInterruptibleAsyncTask extends InterruptibleTask<ListenableFuture<V>>
InterruptibleTask.Blocker| Modifier and Type | Field and Description |
|---|---|
private AsyncCallable<V> |
callable |
| Constructor and Description |
|---|
TrustedFutureInterruptibleAsyncTask(AsyncCallable<V> callable) |
| 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(ListenableFuture<V> result)
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) ListenableFuture<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, toStringprivate final AsyncCallable<V> callable
TrustedFutureInterruptibleAsyncTask(AsyncCallable<V> callable)
final boolean isDone()
InterruptibleTaskisDone in class InterruptibleTask<ListenableFuture<V>>ListenableFuture<V> runInterruptibly() throws java.lang.Exception
InterruptibleTaskrunInterruptibly in class InterruptibleTask<ListenableFuture<V>>java.lang.Exceptionvoid afterRanInterruptiblySuccess(ListenableFuture<V> result)
InterruptibleTaskafterRanInterruptiblySuccess in class InterruptibleTask<ListenableFuture<V>>void afterRanInterruptiblyFailure(java.lang.Throwable error)
InterruptibleTaskafterRanInterruptiblyFailure in class InterruptibleTask<ListenableFuture<V>>java.lang.String toPendingString()
toPendingString in class InterruptibleTask<ListenableFuture<V>>