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

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

ARRAY_BASE

private static final long ARRAY_BASE

ELEMENT_SHIFT

private static final int ELEMENT_SHIFT

sequenceBuffer

protected final long[] sequenceBuffer

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)