Top Fields Constructors Methods
rx.internal.util.unsafe

public abstract Class ConcurrentSequencedCircularArrayQueue<E>

extends ConcurrentCircularArrayQueue<E>
Class Inheritance
Known Direct Subclasses
rx.internal.util.unsafe.MpmcArrayQueueL1Pad
Annotations
@SuppressAnimalSniffer
Static Imports
rx.internal.util.unsafe.UnsafeAccess.UNSAFE

Field Summary

Modifier and TypeField and Description
private static final long
ARRAY_BASE

private static final int
ELEMENT_SHIFT

protected final long[]
sequenceBuffer

Inherited from rx.internal.util.unsafe.ConcurrentCircularArrayQueue:
bufferBUFFER_PADmaskSPARSE_SHIFT

Constructor Summary

AccessConstructor and Description
public
ConcurrentSequencedCircularArrayQueue(int capacity)

Method Summary

Modifier and TypeMethod and Description
protected final long
calcSequenceOffset(long index)

protected final long
lvSequence(long[] buffer, long offset)

protected final void
soSequence(long[] buffer, long offset, long e)

Inherited from rx.internal.util.unsafe.ConcurrentCircularArrayQueue:
calcElementOffsetcalcElementOffsetcleariteratorlpElementlpElementlvElementlvElementsoElementsoElementspElementspElement

Field Detail

ARRAY_BASEback to summary
private static final long ARRAY_BASE
ELEMENT_SHIFTback to summary
private static final int ELEMENT_SHIFT
sequenceBufferback to summary
protected final long[] sequenceBuffer

Constructor Detail

ConcurrentSequencedCircularArrayQueueback to summary
public ConcurrentSequencedCircularArrayQueue(int capacity)

Method Detail

calcSequenceOffsetback to summary
protected final long calcSequenceOffset(long index)
lvSequenceback to summary
protected final long lvSequence(long[] buffer, long offset)
soSequenceback to summary
protected final void soSequence(long[] buffer, long offset, long e)