jadex.util.collection
Class BlockingQueue

java.lang.Object
  jadex.util.collection.BlockingQueue

All Implemented Interfaces:

IBlockingQueue

public class BlockingQueue
extends Object
implements IBlockingQueue

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.util.collection.IBlockingQueue

IBlockingQueue.ClosedException, IBlockingQueue.TimeoutException

Constructor Summary

BlockingQueue()
Create a blocking queue.

Method Summary

Object	dequeue() Dequeue an element.
Object	dequeue(long timeout) Dequeue an element.
void	enqueue(Object element) Enqueue an element.
static void	main(String[] args) Main for testing.
void	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(Object element)

Enqueue an element.

Specified by:

enqueue in interface IBlockingQueue

Parameters:

element - The element.

dequeue

public Object dequeue(long timeout)
               throws IBlockingQueue.ClosedException,
                      IBlockingQueue.TimeoutException

Dequeue an element.

Specified by:

dequeue in interface IBlockingQueue

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

IBlockingQueue.TimeoutException

dequeue

public Object dequeue()
               throws IBlockingQueue.ClosedException

Dequeue an element.

Specified by:

dequeue in interface IBlockingQueue

Returns:

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

Throws:

IBlockingQueue.ClosedException

setClosed

public void setClosed(boolean closed)

Open/close the queue.

Specified by:

setClosed in interface IBlockingQueue

Parameters:

closed - The closed state.

size

public int size()

Return the size of the queue.

Specified by:

size in interface IBlockingQueue

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