Package rx.internal.util.unsafe

Class SpscArrayQueueProducerFields<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>
All Implemented Interfaces:
Iterable<E>, Collection<E>, Queue<E>, MessagePassingQueue<E>
Direct Known Subclasses:
SpscArrayQueueL2Pad
@SuppressAnimalSniffer abstract class SpscArrayQueueProducerFields<E> extends SpscArrayQueueL1Pad<E>

  • Field Details

    • P_INDEX_OFFSET

      protected static final long P_INDEX_OFFSET

    • producerIndex

      protected long producerIndex

    • producerLookAhead

      protected long producerLookAhead

  • Constructor Details

    • SpscArrayQueueProducerFields

      public SpscArrayQueueProducerFields(int capacity)