Package org.infinispan.util.concurrent

Class ReclosableLatch

java.lang.Object

java.util.concurrent.locks.AbstractOwnableSynchronizer

java.util.concurrent.locks.AbstractQueuedSynchronizer

org.infinispan.util.concurrent.ReclosableLatch

All Implemented Interfaces:

Serializable

public class ReclosableLatch
extends AbstractQueuedSynchronizer

A thread gate, that uses an AbstractQueuedSynchronizer.

This implementation allows you to create a latch with a default state (open or closed), and repeatedly open or close the latch.

Since:

4.0

Author:

Manik Surtani (manik@jboss.org)

See Also:

• Serialized Form

Nested Class Summary

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

AbstractQueuedSynchronizer.ConditionObject

Constructor Summary

Constructors

Constructor	Description
ReclosableLatch()
ReclosableLatch(boolean defaultOpen)

Method Summary

Modifier and Type	Method	Description
final void	await()
final boolean	await(long time, TimeUnit unit)
final void	close()
boolean	isOpened()
final void	open()
String	toString()
final int	tryAcquireShared(int ignored)
final boolean	tryReleaseShared(int state)

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, 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

Constructor Details

ReclosableLatch

public ReclosableLatch()

ReclosableLatch

public ReclosableLatch(boolean defaultOpen)

Method Details

tryAcquireShared

public final int tryAcquireShared(int ignored)

Overrides:

tryAcquireShared in class AbstractQueuedSynchronizer

tryReleaseShared

public final boolean tryReleaseShared(int state)

Overrides:

tryReleaseShared in class AbstractQueuedSynchronizer

open

public final void open()

close

public final void close()

isOpened

public boolean isOpened()

await

public final void await()
                 throws InterruptedException

Throws:

InterruptedException

await

public final boolean await(long time,
 TimeUnit unit)
                    throws InterruptedException

Throws:

InterruptedException

toString

public String toString()

Overrides:

toString in class AbstractQueuedSynchronizer