BlockingQueueFactory<E>
@Plugin(name="JCToolsBlockingQueue", category="Core", elementType="BlockingQueueFactory") public class JCToolsBlockingQueueFactory<E> extends Object implements BlockingQueueFactory<E>
MpscArrayQueue
.Modifier and Type | Class | Description |
---|---|---|
static class |
JCToolsBlockingQueueFactory.WaitStrategy |
ELEMENT_TYPE
Modifier and Type | Method | Description |
---|---|---|
BlockingQueue<E> |
create(int capacity) |
Creates a new BlockingQueue with the specified maximum capacity.
|
static <E> JCToolsBlockingQueueFactory<E> |
createFactory(JCToolsBlockingQueueFactory.WaitStrategy waitStrategy) |
public 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)
Copyright © 1999-2018. All Rights Reserved.
Apache Logging, Apache Log4j, Log4j, Apache, the Apache feather logo, the Apache Logging project logo, and the Apache Log4j logo are trademarks of The Apache Software Foundation.