Package com.google.common.util.concurrent

Class InterruptibleTask<T>

java.lang.Object

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

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

All Implemented Interfaces:

java.io.Serializable, java.lang.Runnable

Direct Known Subclasses:

CombinedFuture.CombinedFutureInterruptibleTask, TrustedListenableFutureTask.TrustedFutureInterruptibleAsyncTask, TrustedListenableFutureTask.TrustedFutureInterruptibleTask

abstract class InterruptibleTask<T>
extends java.util.concurrent.atomic.AtomicReference<java.lang.Runnable>
implements java.lang.Runnable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	InterruptibleTask.DoNothingRunnable

Field Summary

Fields

Modifier and Type	Field	Description
private static java.lang.Runnable	DONE
private static java.lang.Runnable	INTERRUPTING
private static int	MAX_BUSY_WAIT_SPINS
private static java.lang.Runnable	PARKED

Constructor Summary

Constructors

Constructor	Description
InterruptibleTask()

Method Summary

Modifier and Type	Method	Description
(package private) abstract 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	interruptTask()	Interrupts the running task.
(package private) abstract boolean	isDone()	Called before runInterruptibly - if true, runInterruptibly and afterRanInterruptibly will not be called.
void	run()
(package private) abstract T	runInterruptibly()	Do interruptible work here - do not complete Futures here, as their listeners could be interrupted.
(package private) abstract java.lang.String	toPendingString()
java.lang.String	toString()

Methods 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

Methods inherited from class java.lang.Object

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

Field Detail

DONE

private static final java.lang.Runnable DONE

INTERRUPTING

private static final java.lang.Runnable INTERRUPTING

PARKED

private static final java.lang.Runnable PARKED

MAX_BUSY_WAIT_SPINS

private static final int MAX_BUSY_WAIT_SPINS

See Also:

Constant Field Values

Constructor Detail

InterruptibleTask

InterruptibleTask()

Method Detail

run

public final void run()

Specified by:

run in interface java.lang.Runnable

isDone

abstract boolean isDone()

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

runInterruptibly

abstract T runInterruptibly()
                     throws java.lang.Exception

Do interruptible work here - do not complete Futures here, as their listeners could be interrupted.

Throws:

java.lang.Exception

afterRanInterruptibly

abstract 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. Complete Futures here.

interruptTask

final void interruptTask()

Interrupts the running task. Because this internally calls Thread.interrupt() which can in turn invoke arbitrary code it is not safe to call while holding a lock.

toString

public final java.lang.String toString()

Overrides:

toString in class java.util.concurrent.atomic.AtomicReference<java.lang.Runnable>

toPendingString

abstract java.lang.String toPendingString()