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

Nested Classes

Modifier and Type	Class and Description
static class	BlockingQueue.Closed

Constructor Summary

Constructors

Constructor and Description
BlockingQueue()

Method Summary

Modifier and Type	Method and Description
void	close()
int	consumerCount()
int	consumerDeficit()
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

clone, equals, finalize, 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()

consumerDeficit

public int consumerDeficit()

ready

public boolean ready()

pending

public int pending()

getQueue

public java.util.LinkedList getQueue()

setQueue

public void setQueue(java.util.LinkedList queue)