Class AtomicReferenceArrayQueue<E>

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

    abstract class AtomicReferenceArrayQueue<E>
    extends java.util.AbstractQueue<E>
    • Field Summary

      Fields 
      Modifier and Type Field Description
      protected java.util.concurrent.atomic.AtomicReferenceArray<E> buffer  
      protected int mask  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected int calcElementOffset​(long index)  
      protected int calcElementOffset​(long index, int mask)  
      void clear()  
      java.util.Iterator<E> iterator()  
      protected E lpElement​(int offset)  
      protected E lpElement​(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, int offset)  
      protected E lvElement​(int offset)  
      protected E lvElement​(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, int offset)  
      protected void soElement​(int offset, E value)  
      protected void soElement​(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, int offset, E value)  
      protected void spElement​(int offset, E value)  
      protected void spElement​(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, int offset, E value)  
      protected void svElement​(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, int offset, E value)  
      • Methods inherited from class java.util.AbstractQueue

        add, addAll, element, remove
      • Methods inherited from class java.util.AbstractCollection

        contains, containsAll, isEmpty, remove, removeAll, retainAll, size, toArray, toArray, toString
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
      • Methods inherited from interface java.util.Collection

        contains, containsAll, equals, hashCode, isEmpty, parallelStream, remove, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray, toArray
      • Methods inherited from interface java.lang.Iterable

        forEach
      • Methods inherited from interface java.util.Queue

        offer, peek, poll
    • Field Detail

      • buffer

        protected final java.util.concurrent.atomic.AtomicReferenceArray<E> buffer
      • mask

        protected final int mask
    • Constructor Detail

      • AtomicReferenceArrayQueue

        public AtomicReferenceArrayQueue​(int capacity)
    • Method Detail

      • iterator

        public java.util.Iterator<E> iterator()
        Specified by:
        iterator in interface java.util.Collection<E>
        Specified by:
        iterator in interface java.lang.Iterable<E>
        Specified by:
        iterator in class java.util.AbstractCollection<E>
      • clear

        public void clear()
        Specified by:
        clear in interface java.util.Collection<E>
        Overrides:
        clear in class java.util.AbstractQueue<E>
      • calcElementOffset

        protected final int calcElementOffset​(long index,
                                              int mask)
      • calcElementOffset

        protected final int calcElementOffset​(long index)
      • lvElement

        protected final E lvElement​(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer,
                                    int offset)
      • lpElement

        protected final E lpElement​(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer,
                                    int offset)
      • lpElement

        protected final E lpElement​(int offset)
      • spElement

        protected final void spElement​(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer,
                                       int offset,
                                       E value)
      • spElement

        protected final void spElement​(int offset,
                                       E value)
      • soElement

        protected final void soElement​(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer,
                                       int offset,
                                       E value)
      • soElement

        protected final void soElement​(int offset,
                                       E value)
      • svElement

        protected final void svElement​(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer,
                                       int offset,
                                       E value)
      • lvElement

        protected final E lvElement​(int offset)