Package org.jctools.queues.alt

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 long[]	sequenceBuffer

Fields inherited from class org.jctools.queues.alt.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 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

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)