abstract class MpscSequencedArrayQueueConsumerField<E> extends MpscSequencedArrayQueueL2Pad<E>
MessagePassingQueue.Consumer<T>, MessagePassingQueue.ExitCondition, MessagePassingQueue.Supplier<T>, MessagePassingQueue.WaitStrategy
Modifier and Type | Field and Description |
---|---|
private static long |
C_INDEX_OFFSET |
protected long |
consumerIndex |
p20, p21, p22, p23, p24, p25, p26, p30, p31, p32, p33, p34, p35, p36, p37
p10, p11, p12, p13, p14, p15, p16
SEQ_BUFFER_PAD, sequenceBuffer
buffer, mask
p01, p02, p03, p04, p05, p06, p07, p17
UNBOUNDED_CAPACITY
Constructor and Description |
---|
MpscSequencedArrayQueueConsumerField(int capacity) |
Modifier and Type | Method and Description |
---|---|
protected long |
lpConsumerIndex() |
long |
lvConsumerIndex() |
protected void |
soConsumerIndex(long v) |
casProducerIndex, lvProducerIndex
calcSequenceOffset, calcSequenceOffset, lvSequence, soSequence
calcElementOffset, calcElementOffset, capacity, clear, currentConsumerIndex, currentProducerIndex, isEmpty, iterator, size, toString
contains, containsAll, remove, removeAll, retainAll, toArray, toArray
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
drain, drain, drain, fill, fill, fill, offer, peek, poll, relaxedOffer, relaxedPeek, relaxedPoll