com.google.common.util.concurrent

Class CombinedFuture.CombinedFutureInterruptibleTask<T>

java.lang.Object

java.util.concurrent.atomic.AtomicReference<java.lang.Runnable>

com.google.common.util.concurrent.InterruptibleTask<T>

com.google.common.util.concurrent.CombinedFuture.CombinedFutureInterruptibleTask<T>

All Implemented Interfaces:

java.io.Serializable, java.lang.Runnable

Direct Known Subclasses:

CombinedFuture.AsyncCallableInterruptibleTask, CombinedFuture.CallableInterruptibleTask

Enclosing class:

CombinedFuture<V>

private abstract class CombinedFuture.CombinedFutureInterruptibleTask<T>
extends InterruptibleTask<T>

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.Executor	listenerExecutor
(package private) boolean	thrownByExecute

Constructor Summary

Constructors

Constructor and Description
CombinedFutureInterruptibleTask(java.util.concurrent.Executor listenerExecutor)

Method Summary

Modifier and Type	Method and Description
(package private) void	afterRanInterruptibly(T result, java.lang.Throwable error) 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)

Methods inherited from class com.google.common.util.concurrent.InterruptibleTask

interruptTask, run, runInterruptibly, toPendingString, toString

Methods inherited from class java.util.concurrent.atomic.AtomicReference

accumulateAndGet, compareAndSet, get, getAndAccumulate, getAndSet, getAndUpdate, lazySet, set, updateAndGet, weakCompareAndSet

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

listenerExecutor

private final java.util.concurrent.Executor listenerExecutor

thrownByExecute

boolean thrownByExecute

Constructor Detail

CombinedFutureInterruptibleTask

public CombinedFutureInterruptibleTask(java.util.concurrent.Executor listenerExecutor)

Method Detail

isDone

final boolean isDone()

Description copied from class: InterruptibleTask

Called before runInterruptibly - if true, runInterruptibly and afterRanInterruptibly will not be called.

Specified by:

isDone in class InterruptibleTask<T>

execute

final void execute()

afterRanInterruptibly

final void afterRanInterruptibly(T result,
                                 java.lang.Throwable error)

Description copied from class: InterruptibleTask

Any interruption that happens as a result of calling interruptTask will arrive before this method is called. Complete Futures here.

Specified by:

afterRanInterruptibly in class InterruptibleTask<T>

setValue

abstract void setValue(T value)