Package org.jctools.queues

Class MpUnboundedXaddArrayQueueConsumerFields<R extends MpUnboundedXaddChunk<R,E>,E>

java.lang.Object
java.util.AbstractCollection<E>
java.util.AbstractQueue<E>
org.jctools.queues.MpUnboundedXaddArrayQueuePad1<E>
org.jctools.queues.MpUnboundedXaddArrayQueueProducerFields<E>
org.jctools.queues.MpUnboundedXaddArrayQueuePad2<E>
org.jctools.queues.MpUnboundedXaddArrayQueueProducerChunk<R,E>
org.jctools.queues.MpUnboundedXaddArrayQueuePad3<R,E>
org.jctools.queues.MpUnboundedXaddArrayQueueConsumerFields<R,E>
All Implemented Interfaces:
Iterable<E>, Collection<E>, Queue<E>, IndexedQueueSizeUtil.IndexedQueue
Direct Known Subclasses:
MpUnboundedXaddArrayQueuePad5
abstract class MpUnboundedXaddArrayQueueConsumerFields<R extends MpUnboundedXaddChunk<R,E>,E> extends MpUnboundedXaddArrayQueuePad3<R,E>

  • Field Details

    • C_INDEX_OFFSET

      private static final long C_INDEX_OFFSET

    • C_CHUNK_OFFSET

      private static final long C_CHUNK_OFFSET

    • consumerIndex

      private volatile long consumerIndex

    • consumerChunk

      private volatile R extends MpUnboundedXaddChunk<R,E> consumerChunk

  • Constructor Details

    • MpUnboundedXaddArrayQueueConsumerFields

      MpUnboundedXaddArrayQueueConsumerFields()

  • Method Details

    • lvConsumerIndex

      public final long lvConsumerIndex()

    • casConsumerIndex

      final boolean casConsumerIndex(long expect, long newValue)

    • lpConsumerChunk

      final R lpConsumerChunk()

    • lvConsumerChunk

      final R lvConsumerChunk()

    • soConsumerChunk

      final void soConsumerChunk(R newValue)

    • lpConsumerIndex

      final long lpConsumerIndex()

    • soConsumerIndex

      final void soConsumerIndex(long newValue)