public class SpscChunkedArrayQueue<E> extends BaseSpscLinkedArrayQueue<E>
Modifier and Type | Field and Description |
---|---|
private int |
maxQueueCapacity |
private long |
producerQueueLimit |
JUMP
producerBuffer, producerBufferLimit, producerMask
producerIndex
p0, p1, p10, p11, p12, p13, p14, p15, p16, p17, p2, p3, p4, p5, p6, p7
consumerIndex
consumerBuffer, consumerMask
Constructor and Description |
---|
SpscChunkedArrayQueue(int capacity) |
SpscChunkedArrayQueue(int chunkSize,
int capacity) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
offerColdPath(E[] buffer,
long mask,
E e,
long pIndex,
long offset) |
currentConsumerIndex, currentProducerIndex, isEmpty, iterator, linkOldToNew, lvConsumerIndex, lvNextArrayAndUnlink, lvProducerIndex, offer, peek, poll, size, soConsumerIndex, soNext, soProducerIndex, toString, writeToQueue
contains, containsAll, remove, removeAll, retainAll, toArray, toArray
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
private int maxQueueCapacity
private long producerQueueLimit
public SpscChunkedArrayQueue(int capacity)
public SpscChunkedArrayQueue(int chunkSize, int capacity)
protected final boolean offerColdPath(E[] buffer, long mask, E e, long pIndex, long offset)
offerColdPath
in class BaseSpscLinkedArrayQueue<E>