Package org.apache.cassandra.utils.concurrent

Class Semaphore.Standard

java.lang.Object

java.util.concurrent.Semaphore

org.apache.cassandra.utils.concurrent.Semaphore.Standard

All Implemented Interfaces:

Serializable, Semaphore

Enclosing interface:

Semaphore

public static class Semaphore.Standard
extends Semaphore
implements Semaphore

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.cassandra.utils.concurrent.Semaphore

Semaphore.Standard

Constructor Summary

Constructors

Constructor	Description
Standard(int permits)
Standard(int permits, boolean fair)

Method Summary

Modifier and Type	Method	Description
void	acquireThrowUncheckedOnInterrupt(int acquire)	Take permits, waiting indefinitely until available
int	drain()	Semaphore.drain()
int	permits()	Number of permits that are available to be acquired.
boolean	tryAcquireUntil(int acquire, long nanoTimeDeadline)	Semaphore.tryAcquireUntil(int, long)
int	waiting()	Number of permits that have been acquired in excess of available.

Methods inherited from class java.util.concurrent.Semaphore

acquire, acquire, acquireUninterruptibly, acquireUninterruptibly, availablePermits, drainPermits, getQueuedThreads, getQueueLength, hasQueuedThreads, isFair, reducePermits, release, release, toString, tryAcquire, tryAcquire, tryAcquire, tryAcquire

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.cassandra.utils.concurrent.Semaphore

acquire, release, tryAcquire, tryAcquire

Constructor Details

Standard

public Standard(int permits)

Standard

public Standard(int permits,
 boolean fair)

Method Details

drain

public int drain()

Semaphore.drain()

Specified by:

drain in interface Semaphore

permits

public int permits()

Number of permits that are available to be acquired. Semaphore.permits()

Specified by:

permits in interface Semaphore

Returns:

the number of permits presently in this semaphore

waiting

public int waiting()

Number of permits that have been acquired in excess of available. Semaphore.permits()

tryAcquireUntil

public boolean tryAcquireUntil(int acquire,
 long nanoTimeDeadline)
                        throws InterruptedException

Semaphore.tryAcquireUntil(int, long)

Specified by:

tryAcquireUntil in interface Semaphore

Returns:

true iff permits acquired

Throws:

InterruptedException - if interrupted

acquireThrowUncheckedOnInterrupt

public void acquireThrowUncheckedOnInterrupt(int acquire)
                                      throws UncheckedInterruptedException

Description copied from interface: Semaphore

Take permits, waiting indefinitely until available

Specified by:

acquireThrowUncheckedOnInterrupt in interface Semaphore

Throws:

UncheckedInterruptedException - if interrupted