Package kilim.concurrent

Class MPSCQueue<E>

java.lang.Object
kilim.concurrent.MPSCQueueL0Pad
kilim.concurrent.MPSCQueueColdFields<E>
kilim.concurrent.MPSCQueueL1Pad<E>
kilim.concurrent.MPSCQueueTailField<E>
kilim.concurrent.MPSCQueueL2Pad<E>
kilim.concurrent.MPSCQueueHeadField<E>
kilim.concurrent.MPSCQueueL3Pad<E>
kilim.concurrent.MPSCQueue<E>
public class MPSCQueue<E> extends MPSCQueueL3Pad<E>

  • Field Details

  • Constructor Details

    • MPSCQueue

      public MPSCQueue(int capacity)

  • Method Details

    • getHead

      private long getHead()

    • lazySetHead

      private void lazySetHead(long l)

    • getTail

      private long getTail()

    • casTail

      private boolean casTail(long expect, long newValue)

    • add

      public boolean add(E e)

    • elementOffsetInBuffer

      private long elementOffsetInBuffer(long index)

    • offer

      public boolean offer(E e)

    • hasSpace

      public boolean hasSpace()

    • poll

      public E poll()

    • fill

      public void fill(E[] buf)

    • remove

      public E remove()

    • isEmpty

      public boolean isEmpty()

    • element

      public E element()

    • peek

      public E peek()

    • getElement

      private E getElement(long index)

    • size

      public int size()