Package org.jgroups.util

Class ProcessingQueue<T>

java.lang.Object

org.jgroups.util.ProcessingQueue<T>

public class ProcessingQueue<T>
extends Object

A queue with many producers and consumers. However, only one consumer gets to remove and process elements at any given time. This is done through the use of locks.

Since:

3.5

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ProcessingQueue.Handler<T>

Field Summary

Fields

Modifier and Type	Field	Description
protected final ReentrantLock	consumer_lock
protected int	count
protected ProcessingQueue.Handler<T>	handler
protected final ReentrantLock	producer_lock
protected final Queue<T>	queue

Constructor Summary

Constructors

Constructor	Description
ProcessingQueue()

Method Summary

Modifier and Type	Method	Description
void	add(T element)
Queue<T>	getQueue()
protected void	process()
boolean	retainAll(Collection<T> elements)
ProcessingQueue<T>	setHandler(ProcessingQueue.Handler<T> handler)
int	size()
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

queue

protected final Queue<T> queue

producer_lock

protected final ReentrantLock producer_lock

consumer_lock

protected final ReentrantLock consumer_lock

count

protected int count

handler

protected ProcessingQueue.Handler<T> handler

Constructor Details

ProcessingQueue

public ProcessingQueue()

Method Details

getQueue

public Queue<T> getQueue()

size

public int size()

setHandler

public ProcessingQueue<T> setHandler(ProcessingQueue.Handler<T> handler)

add

public void add(T element)

retainAll

public boolean retainAll(Collection<T> elements)

toString

public String toString()

Overrides:

toString in class Object

process

protected void process()