E
- public class SpscGrowableUnpaddedArrayQueue<E> extends BaseSpscLinkedUnpaddedArrayQueue<E>
MessagePassingQueue.Consumer<T>, MessagePassingQueue.ExitCondition, MessagePassingQueue.Supplier<T>, MessagePassingQueue.WaitStrategy
Modifier and Type | Field and Description |
---|---|
private long |
lookAheadStep |
private int |
maxQueueCapacity |
producerBuffer, producerBufferLimit, producerMask
consumerBuffer, consumerMask
UNBOUNDED_CAPACITY
Constructor and Description |
---|
SpscGrowableUnpaddedArrayQueue(int capacity) |
SpscGrowableUnpaddedArrayQueue(int chunkSize,
int capacity) |
Modifier and Type | Method and Description |
---|---|
private void |
adjustLookAheadStep(int capacity) |
int |
capacity() |
(package private) boolean |
offerColdPath(E[] buffer,
long mask,
long index,
long 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
lpProducerIndex, lvProducerIndex, soProducerIndex
lpConsumerIndex, 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 lookAheadStep
public SpscGrowableUnpaddedArrayQueue(int capacity)
public SpscGrowableUnpaddedArrayQueue(int chunkSize, int capacity)
final boolean offerColdPath(E[] buffer, long mask, long index, long offset, E v, MessagePassingQueue.Supplier<? extends E> s)
offerColdPath
in class BaseSpscLinkedUnpaddedArrayQueue<E>
private void adjustLookAheadStep(int capacity)
public int capacity()
MessagePassingQueue.UNBOUNDED_CAPACITY
if not bounded