Package org.frankframework.receivers

Class ResourceLimiter

java.lang.Object

java.util.concurrent.Semaphore

org.frankframework.receivers.ResourceLimiter

All Implemented Interfaces:

Serializable

public class ResourceLimiter
extends Semaphore

ResourceLimiter for limiting the number of resources that can be used in parallel. Contains a maxResourceLimit that can be increased or decreased, separate from the actual permits. See Semaphore for generic details.

See Also:

• Serialized Form

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
int	getMaxResourceLimit()
void	increaseMaxResourceCount(int addition)
void	reduceMaxResourceCount(int reduction)
void	waitUntilAllResourcesAvailable()

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 Details

ResourceLimiter

public ResourceLimiter(int permits)

ResourceLimiter

public ResourceLimiter(int permits,
 boolean fair)

Method Details

increaseMaxResourceCount

public void increaseMaxResourceCount(int addition)

reduceMaxResourceCount

public void reduceMaxResourceCount(int reduction)

getMaxResourceLimit

public int getMaxResourceLimit()

waitUntilAllResourcesAvailable

public void waitUntilAllResourcesAvailable()
                                    throws InterruptedException

Throws:

InterruptedException