org.jpos.util
Class BlockingQueue

java.lang.Object
  org.jpos.util.BlockingQueue

public class BlockingQueue
extends java.lang.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()
java.lang.Object	dequeue()
java.lang.Object	dequeue(long timeout)
void	enqueue(java.lang.Object o)
java.util.LinkedList	getQueue()
int	pending()
boolean	ready()
void	requeue(java.lang.Object o)
void	setQueue(java.util.LinkedList queue)

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockingQueue

public BlockingQueue()

Method Detail

enqueue

public void enqueue(java.lang.Object o)
             throws BlockingQueue.Closed

Throws:

BlockingQueue.Closed

requeue

public void requeue(java.lang.Object o)
             throws BlockingQueue.Closed

Throws:

BlockingQueue.Closed

dequeue

public java.lang.Object dequeue()
                         throws java.lang.InterruptedException,
                                BlockingQueue.Closed

Throws:

java.lang.InterruptedException

BlockingQueue.Closed

dequeue

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

Throws:

java.lang.InterruptedException

BlockingQueue.Closed

close

public void close()

consumerCount

public int consumerCount()

ready

public boolean ready()

pending

public int pending()

getQueue

public java.util.LinkedList getQueue()

setQueue

public void setQueue(java.util.LinkedList queue)