abstract class SpmcAtomicArrayQueueProducerIndexField<E> extends SpmcAtomicArrayQueueL1Pad<E>
MessagePassingQueue.Consumer<T>, MessagePassingQueue.ExitCondition, MessagePassingQueue.Supplier<T>, MessagePassingQueue.WaitStrategy
Modifier and Type | Field and Description |
---|---|
private static java.util.concurrent.atomic.AtomicLongFieldUpdater<SpmcAtomicArrayQueueProducerIndexField> |
P_INDEX_UPDATER |
protected long |
producerIndex |
p01, p02, p03, p04, p05, p06, p07, p10, p11, p12, p13, p14, p15, p16, p17
buffer, mask
UNBOUNDED_CAPACITY
Constructor and Description |
---|
SpmcAtomicArrayQueueProducerIndexField(int capacity) |
Modifier and Type | Method and Description |
---|---|
long |
lvProducerIndex() |
protected void |
soProducerIndex(long newValue) |
calcElementOffset, calcElementOffset, capacity, clear, currentConsumerIndex, currentProducerIndex, isEmpty, iterator, lpElement, lpElement, lvElement, lvElement, size, soElement, soElement, spElement, spElement, svElement, toString
contains, containsAll, remove, removeAll, retainAll, toArray, toArray
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
lvConsumerIndex
drain, drain, drain, fill, fill, fill, offer, peek, poll, relaxedOffer, relaxedPeek, relaxedPoll
private static final java.util.concurrent.atomic.AtomicLongFieldUpdater<SpmcAtomicArrayQueueProducerIndexField> P_INDEX_UPDATER
protected volatile long producerIndex