org.jpos.util
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

static class

BlockingQueue.Closed

Constructor Summary

BlockingQueue()

Method Summary

void	close()
int	consumerCount()
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 java.lang.Object

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

Constructor Detail

BlockingQueue

public BlockingQueue()

Method Detail

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()

ready

public boolean ready()

pending

public int pending()

getQueue

public LinkedList getQueue()

setQueue

public void setQueue(LinkedList queue)