reactor.queue

Class BlockingQueueFactory

java.lang.Object

reactor.queue.BlockingQueueFactory

public class BlockingQueueFactory
extends java.lang.Object

A factory for creating BlockingQueue instances. When available, LinkedTransferQueues will be created, otherwise LinkedBlockingQueues will be created.

Constructor Summary

Constructors

Constructor and Description
BlockingQueueFactory()

Method Summary

Modifier and Type	Method and Description
static <D> java.util.concurrent.BlockingQueue<D>	createQueue() Creates a new BlockingQueue

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockingQueueFactory

public BlockingQueueFactory()

Method Detail

createQueue

public static <D> java.util.concurrent.BlockingQueue<D> createQueue()

Creates a new BlockingQueue

Type Parameters:

D - the type of values that the queue will hold

Returns:

the blocking queue