Class ConcurrentSequencedCircularArray<E>

Direct Known Subclasses:
MpmcArrayConcurrentQueueColdFields, MpmcArrayConcurrentQueueColdFields.ConsumerFields, MpmcArrayConcurrentQueueColdFields.ProducerFields, MpscArrayConcurrentQueueColdFields, MpscArrayConcurrentQueueColdFields.ConsumerFields, MpscArrayConcurrentQueueColdFields.ProducerFields

public abstract class ConcurrentSequencedCircularArray<E> extends ConcurrentCircularArray<E>
  • 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)