Class TrustedListenableFutureTask.TrustedFutureInterruptibleAsyncTask
java.lang.Object
java.util.concurrent.atomic.AtomicReference<Runnable>
com.google.common.util.concurrent.InterruptibleTask<ListenableFuture<V>>
com.google.common.util.concurrent.TrustedListenableFutureTask.TrustedFutureInterruptibleAsyncTask
- All Implemented Interfaces:
Serializable,Runnable
- Enclosing class:
TrustedListenableFutureTask<V>
private final class TrustedListenableFutureTask.TrustedFutureInterruptibleAsyncTask
extends InterruptibleTask<ListenableFuture<V>>
-
Nested Class Summary
Nested classes/interfaces inherited from class com.google.common.util.concurrent.InterruptibleTask
InterruptibleTask.Blocker -
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescription(package private) voidAny interruption that happens as a result of calling interruptTask will arrive before this method is called.(package private) voidAny interruption that happens as a result of calling interruptTask will arrive before this method is called.(package private) final booleanisDone()Called before runInterruptibly - if true, runInterruptibly and afterRanInterruptibly will not be called.(package private) ListenableFuture<V> Do interruptible work here - do not complete Futures here, as their listeners could be interrupted.(package private) StringMethods inherited from class com.google.common.util.concurrent.InterruptibleTask
interruptTask, run, toStringMethods inherited from class java.util.concurrent.atomic.AtomicReference
accumulateAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, get, getAcquire, getAndAccumulate, getAndSet, getAndUpdate, getOpaque, getPlain, lazySet, set, setOpaque, setPlain, setRelease, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
-
Field Details
-
callable
-
-
Constructor Details
-
TrustedFutureInterruptibleAsyncTask
TrustedFutureInterruptibleAsyncTask(AsyncCallable<V> callable)
-
-
Method Details
-
isDone
final boolean isDone()Description copied from class:InterruptibleTaskCalled before runInterruptibly - if true, runInterruptibly and afterRanInterruptibly will not be called.- Specified by:
isDonein classInterruptibleTask<ListenableFuture<V>>
-
runInterruptibly
Description copied from class:InterruptibleTaskDo interruptible work here - do not complete Futures here, as their listeners could be interrupted.- Specified by:
runInterruptiblyin classInterruptibleTask<ListenableFuture<V>>- Throws:
Exception
-
afterRanInterruptiblySuccess
Description copied from class:InterruptibleTaskAny interruption that happens as a result of calling interruptTask will arrive before this method is called. Complete Futures here.- Specified by:
afterRanInterruptiblySuccessin classInterruptibleTask<ListenableFuture<V>>
-
afterRanInterruptiblyFailure
Description copied from class:InterruptibleTaskAny interruption that happens as a result of calling interruptTask will arrive before this method is called. Complete Futures here.- Specified by:
afterRanInterruptiblyFailurein classInterruptibleTask<ListenableFuture<V>>
-
toPendingString
String toPendingString()- Specified by:
toPendingStringin classInterruptibleTask<ListenableFuture<V>>
-