Package jadex.collection

Class BlockingQueue<T>

java.lang.Object

jadex.collection.BlockingQueue<T>

All Implemented Interfaces:

IBlockingQueue<T>

public class BlockingQueue<T>
extends Object
implements IBlockingQueue<T>

A blocking queue allows to enqueue or dequeue elements. It blocks, when it is tried to dequeue an element, but the queue is empty.

Nested Class Summary

Nested classes/interfaces inherited from interface jadex.collection.IBlockingQueue

IBlockingQueue.ClosedException

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	closed	The queue state.
protected List<T>	elems	The element storage.
protected Object	monitor	The monitor.

Constructor Summary

Constructors

Constructor	Description
BlockingQueue()	Create a blocking queue.

Method Summary

Modifier and Type	Method	Description
T	dequeue()	Dequeue an element.
T	dequeue(long timeout)	Dequeue an element.
void	enqueue(T element)	Enqueue an element.
boolean	isClosed()	Check if the queue is closed.
static void	main(String[] args)	Main for testing.
T	peek()	Peek the topmost element without dequeuing it.
List	setClosed(boolean closed)	Open/close the queue.
int	size()	Return the size of the queue.
static void	test1(String[] args)	Main for testing.
static void	test1b(String[] args)	Main for testing.
static void	test2(String[] args)	Main for testing.

Methods inherited from class java.lang.Object

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

Field Details

elems

protected List<T> elems

The element storage.

closed

protected volatile boolean closed

The queue state.

monitor

protected Object monitor

The monitor.

Constructor Details

BlockingQueue

public BlockingQueue()

Create a blocking queue.

Method Details

enqueue

public void enqueue(T element)

Enqueue an element.

Specified by:

enqueue in interface IBlockingQueue<T>

Parameters:

element - The element.

dequeue

public T dequeue(long timeout)
          throws IBlockingQueue.ClosedException,
jadex.common.TimeoutException

Dequeue an element.

Specified by:

dequeue in interface IBlockingQueue<T>

Parameters:

timeout - the time to wait (in millis) or -1 for no timeout.

Returns:

The element. When queue is empty the methods blocks until an element is added or the timeout occurs.

Throws:

IBlockingQueue.ClosedException

jadex.common.TimeoutException

peek

public T peek()
       throws IBlockingQueue.ClosedException

Peek the topmost element without dequeuing it.

Specified by:

peek in interface IBlockingQueue<T>

Returns:

The element. When queue is empty the methods blocks until an element is added.

Throws:

IBlockingQueue.ClosedException

dequeue

public T dequeue()
          throws IBlockingQueue.ClosedException

Dequeue an element.

Specified by:

dequeue in interface IBlockingQueue<T>

Returns:

The element. When queue is empty the methods blocks until an element is added.

Throws:

IBlockingQueue.ClosedException

isClosed

public boolean isClosed()

Check if the queue is closed.

Specified by:

isClosed in interface IBlockingQueue<T>

setClosed

public List setClosed(boolean closed)

Open/close the queue.

Specified by:

setClosed in interface IBlockingQueue<T>

Parameters:

closed - The closed state.

Returns:

The remaining elements after the queue has been closed.

size

public int size()

Return the size of the queue.

Specified by:

size in interface IBlockingQueue<T>

Returns:

The size.

main

public static void main(String[] args)
                 throws InterruptedException

Main for testing.

Throws:

InterruptedException

test1

public static void test1(String[] args)
                  throws InterruptedException

Main for testing.

Throws:

InterruptedException

test1b

public static void test1b(String[] args)
                   throws InterruptedException

Main for testing.

Throws:

InterruptedException

test2

public static void test2(String[] args)
                  throws InterruptedException

Main for testing.

Throws:

InterruptedException