Class CreditsSemaphore

java.lang.Object

org.apache.activemq.artemis.protocol.amqp.util.CreditsSemaphore

public class CreditsSemaphore
extends Object

Constructor Summary

Constructors

Constructor	Description
CreditsSemaphore(int initialCredits)

Method Summary

Modifier and Type	Method	Description
void	acquire()
int	getCredits()
boolean	hasQueuedThreads()
void	release()
void	release(int credits)
void	setCredits(int credits)
boolean	tryAcquire()

Methods inherited from class Object

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

Constructor Details

CreditsSemaphore

public CreditsSemaphore(int initialCredits)

Method Details

acquire

public void acquire()
             throws InterruptedException

Throws:

InterruptedException

tryAcquire

public boolean tryAcquire()

release

public void release()
             throws InterruptedException

Throws:

InterruptedException

release

public void release(int credits)
             throws InterruptedException

Throws:

InterruptedException

setCredits

public void setCredits(int credits)

getCredits

public int getCredits()

hasQueuedThreads

public boolean hasQueuedThreads()