Package rx.internal.util.unsafe

Class SpscArrayQueueConsumerField<E>

java.lang.Object
java.util.AbstractCollection<E>
java.util.AbstractQueue<E>
rx.internal.util.unsafe.ConcurrentCircularArrayQueueL0Pad<E>
rx.internal.util.unsafe.ConcurrentCircularArrayQueue<E>
rx.internal.util.unsafe.SpscArrayQueueColdField<E>
rx.internal.util.unsafe.SpscArrayQueueL1Pad<E>
rx.internal.util.unsafe.SpscArrayQueueProducerFields<E>
rx.internal.util.unsafe.SpscArrayQueueL2Pad<E>
rx.internal.util.unsafe.SpscArrayQueueConsumerField<E>
All Implemented Interfaces:
Iterable<E>, Collection<E>, Queue<E>, MessagePassingQueue<E>
Direct Known Subclasses:
SpscArrayQueueL3Pad
@SuppressAnimalSniffer abstract class SpscArrayQueueConsumerField<E> extends SpscArrayQueueL2Pad<E>

  • Field Details

    • consumerIndex

      protected long consumerIndex

    • C_INDEX_OFFSET

      protected static final long C_INDEX_OFFSET

  • Constructor Details

    • SpscArrayQueueConsumerField

      public SpscArrayQueueConsumerField(int capacity)