public abstract class ConcurrentSequencedCircularArrayQueue<E> extends ConcurrentCircularArrayQueue<E>
MessagePassingQueue.Consumer<T>, MessagePassingQueue.ExitCondition, MessagePassingQueue.Supplier<T>, MessagePassingQueue.WaitStrategy
Modifier and Type | Field and Description |
---|---|
protected static int |
SEQ_BUFFER_PAD |
protected long[] |
sequenceBuffer |
buffer, mask
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
add, addAll, element, remove
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
contains, containsAll, equals, hashCode, parallelStream, remove, removeAll, removeIf, retainAll, spliterator, stream, toArray, toArray
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)
Copyright © 2013–2018. All rights reserved.