org.apache.commons.pipeline.util
Interface BlockingQueueFactory<T>

All Superinterfaces:

QueueFactory<T>

All Known Implementing Classes:

BlockingQueueFactory.ArrayBlockingQueueFactory, BlockingQueueFactory.DelayQueueFactoryL, BlockingQueueFactory.LinkedBlockingQueueFactory, BlockingQueueFactory.PriorityBlockingQueueFactory, BlockingQueueFactory.SynchronousQueueFactory

public interface BlockingQueueFactory<T>
extends QueueFactory<T>

Many StageDriver implementations require for one or more queues to be created. This interface provides a consistent API for factories used to create such queues and supplies a couple of default implementations.

Nested Class Summary

static class	BlockingQueueFactory.ArrayBlockingQueueFactory<T>
static class	BlockingQueueFactory.DelayQueueFactoryL<T extends Delayed>
static class	BlockingQueueFactory.LinkedBlockingQueueFactory<T>
static class	BlockingQueueFactory.PriorityBlockingQueueFactory<T>
static class	BlockingQueueFactory.SynchronousQueueFactory<T>

Nested classes/interfaces inherited from interface org.apache.commons.pipeline.util.QueueFactory

QueueFactory.AbstractQueueFactory<T>, QueueFactory.ConcurrentLinkedQueueFactory<T>, QueueFactory.LinkedListFactory<T>, QueueFactory.PriorityQueueFactory<T>

Method Summary

BlockingQueue<T>

createQueue() Create a new queue.

Method Detail

createQueue

BlockingQueue<T> createQueue()

Description copied from interface: QueueFactory

Create a new queue.

Specified by:

createQueue in interface QueueFactory<T>