@Plugin(name="JCToolsBlockingQueue", category="Core", elementType="BlockingQueueFactory") public class JCToolsBlockingQueueFactory<E> extends java.lang.Object implements BlockingQueueFactory<E>
MpscArrayQueue
.Modifier and Type | Class and Description |
---|---|
private static interface |
JCToolsBlockingQueueFactory.Idle |
private static class |
JCToolsBlockingQueueFactory.MpscBlockingQueue<E>
BlockingQueue wrapper for JCTools multiple producer single consumer array queue.
|
static class |
JCToolsBlockingQueueFactory.WaitStrategy |
Modifier and Type | Field and Description |
---|---|
private JCToolsBlockingQueueFactory.WaitStrategy |
waitStrategy |
ELEMENT_TYPE
Modifier | Constructor and Description |
---|---|
private |
JCToolsBlockingQueueFactory(JCToolsBlockingQueueFactory.WaitStrategy waitStrategy) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.BlockingQueue<E> |
create(int capacity)
Creates a new BlockingQueue with the specified maximum capacity.
|
static <E> JCToolsBlockingQueueFactory<E> |
createFactory(JCToolsBlockingQueueFactory.WaitStrategy waitStrategy) |
private final JCToolsBlockingQueueFactory.WaitStrategy waitStrategy
private JCToolsBlockingQueueFactory(JCToolsBlockingQueueFactory.WaitStrategy waitStrategy)
public java.util.concurrent.BlockingQueue<E> create(int capacity)
BlockingQueueFactory
create
in interface BlockingQueueFactory<E>
capacity
- maximum size of the queue if supported@PluginFactory public static <E> JCToolsBlockingQueueFactory<E> createFactory(@PluginAttribute(value="WaitStrategy",defaultString="PARK") JCToolsBlockingQueueFactory.WaitStrategy waitStrategy)