E
- public class SpscChunkedAtomicArrayQueue<E> extends BaseSpscLinkedAtomicArrayQueue<E>
MessagePassingQueue.Consumer<T>, MessagePassingQueue.ExitCondition, MessagePassingQueue.Supplier<T>, MessagePassingQueue.WaitStrategy
Modifier and Type | Field and Description |
---|---|
private int |
maxQueueCapacity |
private long |
producerQueueLimit |
producerBuffer, producerBufferLimit, producerMask
producerIndex
p0, p1, p10, p11, p12, p13, p14, p15, p16, p17, p2, p3, p4, p5, p6, p7
consumerIndex
consumerBuffer, consumerMask
UNBOUNDED_CAPACITY
Constructor and Description |
---|
SpscChunkedAtomicArrayQueue(int capacity) |
SpscChunkedAtomicArrayQueue(int chunkSize,
int capacity) |
Modifier and Type | Method and Description |
---|---|
int |
capacity() |
(package private) boolean |
offerColdPath(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer,
long mask,
long pIndex,
int offset,
E v,
MessagePassingQueue.Supplier<? extends E> s) |
currentConsumerIndex, currentProducerIndex, drain, drain, drain, fill, fill, fill, isEmpty, iterator, linkOldToNew, lvNextArrayAndUnlink, offer, peek, poll, relaxedOffer, relaxedPeek, relaxedPoll, size, soNext, toString, writeToQueue
lvProducerIndex, soProducerIndex
lvConsumerIndex, soConsumerIndex
contains, containsAll, remove, removeAll, retainAll, toArray, toArray
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
clear
private final int maxQueueCapacity
private long producerQueueLimit
public SpscChunkedAtomicArrayQueue(int capacity)
public SpscChunkedAtomicArrayQueue(int chunkSize, int capacity)
final boolean offerColdPath(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, long mask, long pIndex, int offset, E v, MessagePassingQueue.Supplier<? extends E> s)
offerColdPath
in class BaseSpscLinkedAtomicArrayQueue<E>
public int capacity()
MessagePassingQueue.UNBOUNDED_CAPACITY
if not bounded