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 final long	ARRAY_BASE
private static final int	ELEMENT_SHIFT
protected final long[]	sequenceBuffer

Fields inherited from class ConcurrentCircularArray

buffer, BUFFER_PAD, mask, SPARSE_SHIFT

Fields inherited from class 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 final long	calcSequenceOffset(long index)
protected final long	calcSequenceOffset(long index, long mask)
protected final long	lpSequence(long offset)
protected final long	lpSequenceElement(long[] buffer, long offset)
protected final long	lvSequence(long offset)
protected final long	lvSequence(long[] buffer, long offset)
protected final void	soSequence(long[] buffer, long offset, long e)
protected final void	soSequenceElement(long offset, long e)
protected final void	spSequenceElement(long[] buffer, long offset, long e)
protected final void	spSequenceElement(long offset, long e)
protected final void	svSequenceElement(long[] buffer, long offset, long e)
protected final void	svSequenceElement(long offset, long e)

Methods inherited from class ConcurrentCircularArray

calcOffset, calcOffset, lpElement, lpElement, lvElement, lvElement, soElement, soElement, spElement, spElement, svElement, svElement

Methods inherited from class Object

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

Field Details

ARRAY_BASE

private static final long ARRAY_BASE

ELEMENT_SHIFT

private static final int ELEMENT_SHIFT

sequenceBuffer

protected final long[] sequenceBuffer

Constructor Details

ConcurrentSequencedCircularArray

public ConcurrentSequencedCircularArray(int capacity)

ConcurrentSequencedCircularArray

public ConcurrentSequencedCircularArray(ConcurrentSequencedCircularArray<E> c)

Method Details

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)