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

ReclosableLatch()

ReclosableLatch(boolean defaultOpen)

Method Summary

void	await()
boolean	await(long time, TimeUnit unit)
void	close()
boolean	isOpened()
void	open()
String	toString()
int	tryAcquireShared(int ignored)
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, 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 Detail

ReclosableLatch

public ReclosableLatch()

ReclosableLatch

public ReclosableLatch(boolean defaultOpen)

Method Detail

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