public class SpscChunkedAtomicArrayQueue<E> extends BaseSpscLinkedAtomicArrayQueue<E>
Modifier and Type | Field and Description |
---|---|
private int |
maxQueueCapacity |
private long |
producerQueueLimit |
JUMP
producerBuffer, producerBufferLimit, producerMask
P_INDEX_UPDATER, producerIndex
p0, p1, p10, p11, p12, p13, p14, p15, p16, p17, p2, p3, p4, p5, p6, p7
C_INDEX_UPDATER, consumerIndex
consumerBuffer, consumerMask
Constructor and Description |
---|
SpscChunkedAtomicArrayQueue(int capacity) |
SpscChunkedAtomicArrayQueue(int chunkSize,
int capacity) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
offerColdPath(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer,
long mask,
E e,
long pIndex,
int offset) |
allocate, calcElementOffset, currentConsumerIndex, currentProducerIndex, isEmpty, iterator, linkOldToNew, lvConsumerIndex, lvElement, 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 SpscChunkedAtomicArrayQueue(int capacity)
public SpscChunkedAtomicArrayQueue(int chunkSize, int capacity)
protected final boolean offerColdPath(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, long mask, E e, long pIndex, int offset)
offerColdPath
in class BaseSpscLinkedAtomicArrayQueue<E>