Class MpmcRingBuffer<E>

java.lang.Object
org.eclipse.rdf4j.sail.lmdb.util.MpmcRingBuffer<E>
public final class MpmcRingBuffer<E> extends Object
Bounded lock-free MPMC queue (Vyukov scheme).

Each slot carries a sequence number that encodes its state: a slot at index i is writable when its sequence equals the current enqueue position, and readable when it equals the dequeue position plus one.

  • Constructor Details

    • MpmcRingBuffer

      public MpmcRingBuffer(int capacity)

  • Method Details

    • offer

      public boolean offer(E item)

    • poll

      public E poll()