Package io.atlassian.fugue

Class Iterables.LazyReference.Sync

java.lang.Object

java.util.concurrent.locks.AbstractOwnableSynchronizer

java.util.concurrent.locks.AbstractQueuedSynchronizer

io.atlassian.fugue.Iterables.LazyReference.Sync

All Implemented Interfaces:

Serializable

Enclosing class:

Iterables.LazyReference<T>

private final class Iterables.LazyReference.Sync
extends AbstractQueuedSynchronizer

Synchronization control for LazyReference. Note that this must be a non-static inner class in order to invoke the protected {code}create{/code} method. Taken from FutureTask AQS implementation and pruned to be as compact as possible. Uses AQS sync state to represent run status.

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.locks.AbstractQueuedSynchronizer

AbstractQueuedSynchronizer.ConditionObject

Field Summary

Fields

Modifier and Type	Field	Description
private Throwable	exception	The exception to throw from get()
(package private) static final int	IGNORED
private T	result	The result to return from get()
private Thread	runner	The thread running task.
private static final long	serialVersionUID	only here to shut up the compiler warnings, the outer class is NOT serializable

Constructor Summary

Constructors

Modifier	Constructor	Description
private	Sync()

Method Summary

Modifier and Type	Method	Description
(package private) void	cancel(boolean mayInterruptIfRunning)
(package private) T	get()
(package private) boolean	isDone()
private boolean	ranOrCancelled(int state)
(package private) void	run()
(package private) void	set(T v)
(package private) void	setException(Throwable t)
protected int	tryAcquireShared(int ignore)	Implements AQS base acquire to succeed if ran or cancelled
protected boolean	tryReleaseShared(int ignore)	Implements AQS base release to always signal after setting final done status by nulling runner thread.

Methods inherited from class java.util.concurrent.locks.AbstractQueuedSynchronizer

acquire, acquireInterruptibly, acquireShared, acquireSharedInterruptibly, compareAndSetState, getExclusiveQueuedThreads, getFirstQueuedThread, getQueuedThreads, getQueueLength, getSharedQueuedThreads, getState, getWaitingThreads, getWaitQueueLength, hasContended, hasQueuedPredecessors, hasQueuedThreads, hasWaiters, isHeldExclusively, isQueued, owns, release, releaseShared, setState, toString, tryAcquire, tryAcquireNanos, tryAcquireSharedNanos, tryRelease

Methods inherited from class java.util.concurrent.locks.AbstractOwnableSynchronizer

getExclusiveOwnerThread, setExclusiveOwnerThread

Methods inherited from class java.lang.Object

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

Field Details

IGNORED

static final int IGNORED

See Also:

• Constant Field Values

serialVersionUID

private static final long serialVersionUID

only here to shut up the compiler warnings, the outer class is NOT serializable

See Also:

• Constant Field Values

result

private T result

The result to return from get()

exception

private Throwable exception

The exception to throw from get()

runner

private volatile Thread runner

The thread running task. When nulled after set/cancel, this indicates that the results are accessible. Must be volatile, to ensure visibility upon completion.

Constructor Details

Sync

private Sync()

Method Details

ranOrCancelled

private boolean ranOrCancelled(int state)

tryAcquireShared

protected int tryAcquireShared(int ignore)

Implements AQS base acquire to succeed if ran or cancelled

Overrides:

tryAcquireShared in class AbstractQueuedSynchronizer

tryReleaseShared

protected boolean tryReleaseShared(int ignore)

Implements AQS base release to always signal after setting final done status by nulling runner thread.

Overrides:

tryReleaseShared in class AbstractQueuedSynchronizer

isDone

boolean isDone()

get

T get()
throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

set

void set(T v)

setException

void setException(Throwable t)

cancel

void cancel(boolean mayInterruptIfRunning)

run

void run()