com.github.rholder.moar.concurrent

Class StrategicQueues

java.lang.Object

com.github.rholder.moar.concurrent.StrategicQueues

public class StrategicQueues
extends java.lang.Object

This is a helper class for instantiating StrategicBlockingQueue's.

Constructor Summary

Constructors

Constructor and Description
StrategicQueues()

Method Summary

Methods

Modifier and Type	Method and Description
static <V> StrategicBlockingQueue<V>	newStrategicArrayBlockingQueue(int capacity, QueueingStrategy<V> queueingStrategy) Return a StrategicBlockingQueue backed by an ArrayBlockingQueue of the given capacity using the given QueueingStrategy.
static <V> StrategicBlockingQueue<V>	newStrategicBlockingQueue(java.util.concurrent.BlockingQueue<V> blockingQueue, QueueingStrategy<V> queueingStrategy) Return a StrategicBlockingQueue backed by the given BlockingQueue using the given QueueingStrategy.
static <V> StrategicBlockingQueue<V>	newStrategicLinkedBlockingQueue(QueueingStrategy<V> queueingStrategy) Return a StrategicBlockingQueue backed by a LinkedBlockingQueue using the given QueueingStrategy.

Methods inherited from class java.lang.Object

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

Constructor Detail

StrategicQueues

public StrategicQueues()

Method Detail

newStrategicLinkedBlockingQueue

public static <V> StrategicBlockingQueue<V> newStrategicLinkedBlockingQueue(QueueingStrategy<V> queueingStrategy)

Return a StrategicBlockingQueue backed by a LinkedBlockingQueue using the given QueueingStrategy.

Type Parameters:

V - the type of elements held in this collection

Parameters:

queueingStrategy - the QueueingStrategy to use

newStrategicArrayBlockingQueue

public static <V> StrategicBlockingQueue<V> newStrategicArrayBlockingQueue(int capacity,
                                                           QueueingStrategy<V> queueingStrategy)

Return a StrategicBlockingQueue backed by an ArrayBlockingQueue of the given capacity using the given QueueingStrategy.

Type Parameters:

V - the type of elements held in this collection

Parameters:

capacity - the capacity of the ArrayBlockingQueue

queueingStrategy - the QueueingStrategy to use

newStrategicBlockingQueue

public static <V> StrategicBlockingQueue<V> newStrategicBlockingQueue(java.util.concurrent.BlockingQueue<V> blockingQueue,
                                                      QueueingStrategy<V> queueingStrategy)

Return a StrategicBlockingQueue backed by the given BlockingQueue using the given QueueingStrategy.

Type Parameters:

V - the type of elements held in this collection

Parameters:

blockingQueue - the BlockingQueue to back the returned instance

queueingStrategy - the QueueingStrategy to use