org.jbrew.concurrent

Class UnboundedTaskQueue

java.lang.Object

org.jbrew.concurrent.AbstractBlockingTaskQueue

org.jbrew.concurrent.UnboundedTaskQueue

All Implemented Interfaces:

TaskQueue<Task<? extends Object>>

public class UnboundedTaskQueue
extends AbstractBlockingTaskQueue

A BoundedTaskQueue is an unordered, unbounded implementation of a TaskQueue. This implementation is ThreadSafe, as it can safely handle multiple consumer and producer threads writing and/or reading from it.

Author:

nealk

Field Summary

Fields inherited from class org.jbrew.concurrent.AbstractBlockingTaskQueue

queue

Constructor Summary

Constructors

Constructor and Description
UnboundedTaskQueue()

Method Summary

Modifier and Type	Method and Description
void	enqueue(Task<? extends Object> task) Adds an element to the head of the queue.

Methods inherited from class org.jbrew.concurrent.AbstractBlockingTaskQueue

dequeue

Methods inherited from class java.lang.Object

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

Constructor Detail

UnboundedTaskQueue

public UnboundedTaskQueue()

Method Detail

enqueue

public void enqueue(Task<? extends Object> task)
             throws InterruptedException

Description copied from interface: TaskQueue

Adds an element to the head of the queue. When the queue is full (bounded implementations only), the calling Thread is blocked until capacity in the queue has been released.

Parameters:

task - - The Task which is being added to the queue.

Throws:

InterruptedException - - The method hands off the responsibility of exception handling to the caller in event of an interruption in the Thread.