Class SpscUnboundedArrayQueue<E>

Type Parameters:
E -
All Implemented Interfaces:
Iterable<E>, Collection<E>, Queue<E>, IndexedQueueSizeUtil.IndexedQueue, MessagePassingQueue<E>, QueueProgressIndicators

public class SpscUnboundedArrayQueue<E> extends BaseSpscLinkedArrayQueue<E>
An SPSC array queue which starts at initialCapacity and grows indefinitely in linked chunks of the initial size. The queue grows only when the current chunk is full and elements are not copied on resize, instead a link to the new chunk is stored in the old chunk for the consumer to follow.
  • Constructor Details

    • SpscUnboundedArrayQueue

      public SpscUnboundedArrayQueue(int chunkSize)
  • Method Details