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:
java.io.Serializable
- Enclosing class:
- ReentrantCircuit
private static final class ReentrantCircuit.Sync extends java.util.concurrent.locks.AbstractQueuedSynchronizer
Synchronization state of 0 = closed, 1 = open.
-
-
Field Summary
Fields Modifier and Type Field Description private static long
serialVersionUID
-
Constructor Summary
Constructors Modifier Constructor Description private
Sync()
-
Method Summary
All Methods Instance Methods Concrete Methods 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 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
-
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
-
Method Detail
-
tryReleaseShared
public boolean tryReleaseShared(int ignored)
Closes the circuit.- Overrides:
tryReleaseShared
in classjava.util.concurrent.locks.AbstractQueuedSynchronizer
-
tryAcquireShared
protected int tryAcquireShared(int acquires)
Opens the circuit if not a test.- Overrides:
tryAcquireShared
in classjava.util.concurrent.locks.AbstractQueuedSynchronizer
-
isClosed
private boolean isClosed()
-
open
private void open()
-
-