Class ConcurrentSequencedCircularArray<E>

java.lang.Object

org.jctools.queues.alt.ConcurrentCircularArray<E>

org.jctools.queues.alt.ConcurrentSequencedCircularArray<E>

Direct Known Subclasses:

MpmcArrayConcurrentQueue, MpscArrayConcurrentQueue

public abstract class ConcurrentSequencedCircularArray<E>
extends ConcurrentCircularArray<E>

Field Summary

Fields

Modifier and Type	Field	Description
protected final long[]	sequenceBuffer

Fields inherited from class ConcurrentCircularArray

buffer, BUFFER_PAD, mask, SPARSE_SHIFT

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

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)