Package org.jctools.queues.alt
Class ConcurrentSequencedCircularArray<E>
- java.lang.Object
-
- org.jctools.queues.alt.ConcurrentCircularArrayL0Pad<E>
-
- org.jctools.queues.alt.ConcurrentCircularArray<E>
-
- org.jctools.queues.alt.ConcurrentSequencedCircularArray<E>
-
- Direct Known Subclasses:
MpmcArrayConcurrentQueueColdFields
,MpmcArrayConcurrentQueueColdFields.ConsumerFields
,MpmcArrayConcurrentQueueColdFields.ProducerFields
,MpscArrayConcurrentQueueColdFields
,MpscArrayConcurrentQueueColdFields.ConsumerFields
,MpscArrayConcurrentQueueColdFields.ProducerFields
public abstract class ConcurrentSequencedCircularArray<E> extends ConcurrentCircularArray<E>
-
-
Field Summary
Fields Modifier and Type Field Description private static long
ARRAY_BASE
private static int
ELEMENT_SHIFT
protected long[]
sequenceBuffer
-
Fields inherited from class org.jctools.queues.alt.ConcurrentCircularArray
buffer, BUFFER_PAD, mask, SPARSE_SHIFT
-
Fields inherited from class org.jctools.queues.alt.ConcurrentCircularArrayL0Pad
b000, b001, b002, b003, b004, b005, b006, b007, b010, b011, b012, b013, b014, b015, b016, b017, b020, b021, b022, b023, b024, b025, b026, b027, b030, b031, b032, b033, b034, b035, b036, b037, b040, b041, b042, b043, b044, b045, b046, b047, b050, b051, b052, b053, b054, b055, b056, b057, b060, b061, b062, b063, b064, b065, b066, b067, b070, b071, b072, b073, b074, b075, b076, b077, b100, b101, b102, b103, b104, b105, b106, b107, b110, b111, b112, b113, b114, b115, b116, b117, b120, b121, b122, b123, b124, b125, b126, b127, b130, b131, b132, b133, b134, b135, b136, b137, b140, b141, b142, b143, b144, b145, b146, b147, b150, b151, b152, b153, b154, b155, b156, b157, b160, b161, b162, b163, b164, b165, b166, b167, b170, b171, b172, b173, b174, b175, b176, b177
-
-
Constructor Summary
Constructors Constructor Description ConcurrentSequencedCircularArray(int capacity)
ConcurrentSequencedCircularArray(ConcurrentSequencedCircularArray<E> c)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected long
calcSequenceOffset(long index)
protected long
calcSequenceOffset(long index, long mask)
protected long
lpSequence(long offset)
protected long
lpSequenceElement(long[] buffer, long offset)
protected long
lvSequence(long offset)
protected long
lvSequence(long[] buffer, long offset)
protected void
soSequence(long[] buffer, long offset, long e)
protected void
soSequenceElement(long offset, long e)
protected void
spSequenceElement(long[] buffer, long offset, long e)
protected void
spSequenceElement(long offset, long e)
protected void
svSequenceElement(long[] buffer, long offset, long e)
protected void
svSequenceElement(long offset, long e)
-
Methods inherited from class org.jctools.queues.alt.ConcurrentCircularArray
calcOffset, calcOffset, lpElement, lpElement, lvElement, lvElement, soElement, soElement, spElement, spElement, svElement, svElement
-
-
-
-
Constructor Detail
-
ConcurrentSequencedCircularArray
public ConcurrentSequencedCircularArray(int capacity)
-
ConcurrentSequencedCircularArray
public ConcurrentSequencedCircularArray(ConcurrentSequencedCircularArray<E> c)
-
-
Method Detail
-
calcSequenceOffset
protected final long calcSequenceOffset(long index)
-
calcSequenceOffset
protected final long calcSequenceOffset(long index, long mask)
-
spSequenceElement
protected final void spSequenceElement(long offset, long e)
-
soSequenceElement
protected final void soSequenceElement(long offset, long e)
-
svSequenceElement
protected final void svSequenceElement(long offset, long e)
-
lpSequence
protected final long lpSequence(long offset)
-
lvSequence
protected final long lvSequence(long offset)
-
spSequenceElement
protected final void spSequenceElement(long[] buffer, long offset, long e)
-
soSequence
protected final void soSequence(long[] buffer, long offset, long e)
-
svSequenceElement
protected final void svSequenceElement(long[] buffer, long offset, long e)
-
lpSequenceElement
protected final long lpSequenceElement(long[] buffer, long offset)
-
lvSequence
protected final long lvSequence(long[] buffer, long offset)
-
-