Class MpscOnSpscFields<E>

  • All Implemented Interfaces:
    java.lang.Iterable<E>, java.util.Collection<E>, java.util.Queue<E>
    Direct Known Subclasses:
    MpscOnSpscQueue

    abstract class MpscOnSpscFields<E>
    extends MpscOnSpscL0Pad<E>
    • Field Detail

      • QUEUES_OFFSET

        private static final long QUEUES_OFFSET
      • producerQueue

        protected final java.lang.ThreadLocal<java.util.Queue<E>> producerQueue
      • refQ

        java.lang.ref.ReferenceQueue<java.lang.Thread> refQ
      • queues

        protected volatile java.util.Queue<E>[] queues
    • Constructor Detail

      • MpscOnSpscFields

        public MpscOnSpscFields​(int capacity)
    • Method Detail

      • addQueue

        protected final void addQueue​(java.util.Queue<E> q)
      • removeQueue

        protected final void removeQueue​(java.lang.Object q)
      • numberOfQueues

        int numberOfQueues()