jadex.commons.collection

Class BlockingQueue<T>

java.lang.Object

jadex.commons.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.commons.collection.IBlockingQueue

IBlockingQueue.ClosedException

Constructor Summary

Constructors

Constructor and Description
BlockingQueue() Create a blocking queue.

Method Summary

Methods

Modifier and Type	Method and 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

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

Constructor Detail

BlockingQueue

public BlockingQueue()

Create a blocking queue.

Method Detail

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,
                 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

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