org.apache.giraph.utils

Class AdjustableSemaphore

java.lang.Object

java.util.concurrent.Semaphore

org.apache.giraph.utils.AdjustableSemaphore

All Implemented Interfaces:

Serializable

public final class AdjustableSemaphore
extends Semaphore

Implementation of a semaphore where number of available permits can change

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AdjustableSemaphore(int permits) Constructor

Method Summary

Modifier and Type	Method and Description
int	getMaxPermits()
void	setMaxPermits(int newMax) Adjusts the maximum number of available permits.

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

Constructor Detail

AdjustableSemaphore

public AdjustableSemaphore(int permits)

Constructor

Parameters:

permits - initial number of available permits

Method Detail

getMaxPermits

public int getMaxPermits()

setMaxPermits

public void setMaxPermits(int newMax)

Adjusts the maximum number of available permits.

Parameters:

newMax - max number of permits