Package org.jctools.queues.blocking
Class BlockingQueueFactory
java.lang.Object
org.jctools.queues.blocking.BlockingQueueFactory
The queue factory produces
Queue
instances based on a best fit to the ConcurrentQueueSpec
.
This allows minimal dependencies between user code and the queue implementations and gives users a way to express
their requirements on a higher level.-
Nested Class Summary
Nested Classes -
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate static <E> BlockingQueue
<E> getBlockingQueueFrom
(Class<? extends Queue> queueClass, Class<? extends TakeStrategy> takeStrat, Class<? extends PutStrategy> putStrat, int capacity) static <E> BlockingQueue
<E> static <E> BlockingQueue
<E> newBlockingQueue
(ConcurrentQueueSpec qs, Class<? extends TakeStrategy> takeStratClass, Class<? extends PutStrategy> putStratClass)
-
Field Details
-
blockingQueueCache
-
-
Constructor Details
-
BlockingQueueFactory
public BlockingQueueFactory()
-
-
Method Details
-
newBlockingQueue
-
newBlockingQueue
public static <E> BlockingQueue<E> newBlockingQueue(ConcurrentQueueSpec qs, Class<? extends TakeStrategy> takeStratClass, Class<? extends PutStrategy> putStratClass) -
getBlockingQueueFrom
private static <E> BlockingQueue<E> getBlockingQueueFrom(Class<? extends Queue> queueClass, Class<? extends TakeStrategy> takeStrat, Class<? extends PutStrategy> putStrat, int capacity)
-