com.google.common.util.concurrent

Class CombinedFuture.CombinedFutureInterruptibleTask

java.lang.Object

com.google.common.util.concurrent.InterruptibleTask

com.google.common.util.concurrent.CombinedFuture.CombinedFutureInterruptibleTask

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

CombinedFuture.AsyncCallableInterruptibleTask, CombinedFuture.CallableInterruptibleTask

Enclosing class:

CombinedFuture<V>

private abstract class CombinedFuture.CombinedFutureInterruptibleTask
extends InterruptibleTask

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	execute()
(package private) void	runInterruptibly()
(package private) abstract void	setValue()
(package private) boolean	wasInterrupted()

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

interruptTask, run

Methods inherited from class java.lang.Object

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

Field Detail

listenerExecutor

private final java.util.concurrent.Executor listenerExecutor

thrownByExecute

volatile boolean thrownByExecute

Constructor Detail

CombinedFutureInterruptibleTask

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

Method Detail

runInterruptibly

final void runInterruptibly()

Specified by:

runInterruptibly in class InterruptibleTask

wasInterrupted

final boolean wasInterrupted()

Specified by:

wasInterrupted in class InterruptibleTask

execute

final void execute()

setValue

abstract void setValue()
                throws java.lang.Exception

Throws:

java.lang.Exception