ds.funnel.node.event

Class EventLimiter

java.lang.Object

ds.funnel.node.event.EventLimiter

public class EventLimiter
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	EventLimiter.QueueSemaphore

Constructor Summary

Constructors

Constructor and Description
EventLimiter(java.util.concurrent.locks.ReentrantLock inLock)

Method Summary

Modifier and Type	Method and Description
void	await(int inPermits)
EventLimiter.QueueSemaphore	getSemaphore(int inMaxPermits)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EventLimiter

public EventLimiter(java.util.concurrent.locks.ReentrantLock inLock)

Method Detail

getSemaphore

public EventLimiter.QueueSemaphore getSemaphore(int inMaxPermits)

await

public void await(int inPermits)
           throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException