public abstract class ConcurrentSequencedCircularArrayQueue<E> extends ConcurrentCircularArrayQueue<E>
MessagePassingQueue.Consumer<T>, MessagePassingQueue.ExitCondition, MessagePassingQueue.Supplier<T>, MessagePassingQueue.WaitStrategy
Modifier and Type | Field and Description |
---|---|
private static long |
ARRAY_BASE |
private static int |
ELEMENT_SHIFT |
protected static int |
SEQ_BUFFER_PAD |
protected long[] |
sequenceBuffer |
buffer, mask
p01, p02, p03, p04, p05, p06, p07, p10, p11, p12, p13, p14, p15, p16, p17
UNBOUNDED_CAPACITY
Constructor and Description |
---|
ConcurrentSequencedCircularArrayQueue(int capacity) |
Modifier and Type | Method and Description |
---|---|
protected long |
calcSequenceOffset(long index) |
protected static long |
calcSequenceOffset(long index,
long mask) |
protected long |
lvSequence(long[] buffer,
long offset) |
protected void |
soSequence(long[] buffer,
long offset,
long e) |
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
lvConsumerIndex, lvProducerIndex
private static final long ARRAY_BASE
private static final int ELEMENT_SHIFT
protected static final int SEQ_BUFFER_PAD
protected final long[] sequenceBuffer
public ConcurrentSequencedCircularArrayQueue(int capacity)
protected final long calcSequenceOffset(long index)
protected static long calcSequenceOffset(long index, long mask)
protected final void soSequence(long[] buffer, long offset, long e)
protected final long lvSequence(long[] buffer, long offset)