abstract class SpmcArrayQueueConsumerField<E> extends SpmcArrayQueueL2Pad<E>
MessagePassingQueue.Consumer<T>, MessagePassingQueue.ExitCondition, MessagePassingQueue.Supplier<T>, MessagePassingQueue.WaitStrategy
Modifier and Type | Field and Description |
---|---|
protected static long |
C_INDEX_OFFSET |
private long |
consumerIndex |
p01, p02, p03, p04, p05, p06, p07, p10, p11, p12, p13, p14, p15, p16, p17
P_INDEX_OFFSET, producerIndex
buffer, mask
UNBOUNDED_CAPACITY
Constructor and Description |
---|
SpmcArrayQueueConsumerField(int capacity) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
casHead(long expect,
long newValue) |
protected long |
lvConsumerIndex() |
lvProducerIndex, soProducerIndex
calcElementOffset, calcElementOffset, capacity, clear, iterator
contains, containsAll, isEmpty, remove, removeAll, retainAll, size, toArray, toArray, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
drain, drain, drain, fill, fill, fill, isEmpty, offer, peek, poll, relaxedOffer, relaxedPeek, relaxedPoll, size