Class BlockingQueue

java.lang.Object

org.jpos.util.BlockingQueue

public class BlockingQueue
extends Object

implements a blocking queue

Since:

1.1

See Also:

• ThreadPool

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BlockingQueue.Closed

Constructor Summary

Constructors

Constructor	Description
BlockingQueue()

Method Summary

Modifier and Type	Method	Description
void	close()
int	consumerCount()
int	consumerDeficit()
Object	dequeue()
Object	dequeue(long timeout)
void	enqueue(Object o)
LinkedList	getQueue()
int	pending()
boolean	ready()
void	requeue(Object o)
void	setQueue(LinkedList queue)

Methods inherited from class Object

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

Constructor Details

BlockingQueue

public BlockingQueue()

Method Details

enqueue

public void enqueue(Object o)
             throws BlockingQueue.Closed

Throws:

BlockingQueue.Closed

requeue

public void requeue(Object o)
             throws BlockingQueue.Closed

Throws:

BlockingQueue.Closed

dequeue

public Object dequeue()
               throws InterruptedException,
BlockingQueue.Closed

Throws:

InterruptedException

BlockingQueue.Closed

dequeue

public Object dequeue(long timeout)
               throws InterruptedException,
BlockingQueue.Closed

Throws:

InterruptedException

BlockingQueue.Closed

close

public void close()

consumerCount

public int consumerCount()

consumerDeficit

public int consumerDeficit()

ready

public boolean ready()

pending

public int pending()

getQueue

public LinkedList getQueue()

setQueue

public void setQueue(LinkedList queue)