Class ReentrantCircuit.Sync

java.lang.Object

java.util.concurrent.locks.AbstractOwnableSynchronizer

java.util.concurrent.locks.AbstractQueuedSynchronizer

net.jodah.concurrentunit.internal.ReentrantCircuit.Sync

All Implemented Interfaces:

Serializable

Enclosing class:

ReentrantCircuit

private static final class ReentrantCircuit.Sync
extends AbstractQueuedSynchronizer

Synchronization state of 0 = closed, 1 = open.

Nested Class Summary

Nested classes/interfaces inherited from class AbstractQueuedSynchronizer

AbstractQueuedSynchronizer.ConditionObject

Field Summary

Fields

Modifier and Type	Field	Description
private static final long	serialVersionUID

Constructor Summary

Constructors

Modifier	Constructor	Description
private	Sync()

Method Summary

Modifier and Type	Method	Description
private boolean	isClosed()
private void	open()
protected int	tryAcquireShared(int acquires)	Opens the circuit if not a test.
boolean	tryReleaseShared(int ignored)	Closes the circuit.

Methods inherited from class 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 AbstractOwnableSynchronizer

getExclusiveOwnerThread, setExclusiveOwnerThread

Methods inherited from class Object

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

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

Constructor Details

Sync

private Sync()

Method Details

tryReleaseShared

public boolean tryReleaseShared(int ignored)

Closes the circuit.

Overrides:

tryReleaseShared in class AbstractQueuedSynchronizer

tryAcquireShared

protected int tryAcquireShared(int acquires)

Opens the circuit if not a test.

Overrides:

tryAcquireShared in class AbstractQueuedSynchronizer

isClosed

private boolean isClosed()

open

private void open()