org.jbrew.concurrent

Class AbstractBlockingTaskQueue

java.lang.Object

org.jbrew.concurrent.AbstractBlockingTaskQueue

All Implemented Interfaces:

TaskQueue<Task<? extends Object>>

Direct Known Subclasses:

BoundedTaskQueue, UnboundedTaskQueue

public abstract class AbstractBlockingTaskQueue
extends Object
implements TaskQueue<Task<? extends Object>>

A AbstractBlockingTaskQueue provides a skeletal implementation of the TaskQueue interface. To implement an un/bounded queue of Task, the programmer only needs to extend this class and concretely implement its abstract methods.

Author:

nealk

Field Summary

Fields

Modifier and Type	Field and Description
protected Queue<Task<? extends Object>>	queue

Constructor Summary

Constructors

Constructor and Description
AbstractBlockingTaskQueue()

Method Summary

Modifier and Type	Method and Description
Task<? extends Object>	dequeue() Removes an element from the tail of the queue and returns it.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jbrew.concurrent.TaskQueue

enqueue

Field Detail

queue

protected final Queue<Task<? extends Object>> queue

Constructor Detail

AbstractBlockingTaskQueue

public AbstractBlockingTaskQueue()

Method Detail

dequeue

public final Task<? extends Object> dequeue()

Description copied from interface: TaskQueue

Removes an element from the tail of the queue and returns it. If the queue is empty, the calling Thread is blocked until a Task is added to the queue and it is no longer empty.

Specified by:

dequeue in interface TaskQueue<Task<? extends Object>>

Returns:

The Task which is being removed from the queue.