Top Description Fields Constructors Methods
io.netty.util.internal.shaded.org.jctools.queues

public Class SpscGrowableArrayQueue<E>

extends BaseSpscLinkedArrayQueue<E>
Class Inheritance
Imports
io.netty.util.internal.shaded.org.jctools.util.Pow2, .RangeUtil
An SPSC array queue which starts at initialCapacity and grows to maxCapacity in linked chunks, doubling theirs size every time until the full blown backing array is used. 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.

Field Summary

Modifier and TypeField and Description
private long
lookAheadStep

private final int
maxQueueCapacity

Constructor Summary

AccessConstructor and Description
public
SpscGrowableArrayQueue(final int capacity)

public
SpscGrowableArrayQueue(final int chunkSize, final int capacity)

Method Summary

Modifier and TypeMethod and Description
private void
adjustLookAheadStep(int capacity)

public int
capacity()

Implements io.netty.util.internal.shaded.org.jctools.queues.MessagePassingQueue.capacity, io.netty.util.internal.shaded.org.jctools.queues.IndexedQueueSizeUtil.IndexedQueue.capacity.

pack-priv final boolean
offerColdPath(final E[] buffer, final long mask, final long index, final long offset, final E v, final MessagePassingQueue.Supplier<? extends E> s)

Implements abstract io.netty.util.internal.shaded.org.jctools.queues.BaseSpscLinkedArrayQueue.offerColdPath.

Inherited from io.netty.util.internal.shaded.org.jctools.queues.BaseSpscLinkedArrayQueue:
currentConsumerIndexcurrentProducerIndexdraindraindrainfillfillfillisEmptyiteratorlinkOldToNewlvNextArrayAndUnlinkofferpeekpollrelaxedOfferrelaxedPeekrelaxedPollsizesoNexttoStringwriteToQueue

Field Detail

lookAheadStepback to summary
private long lookAheadStep
maxQueueCapacityback to summary
private final int maxQueueCapacity

Constructor Detail

SpscGrowableArrayQueueback to summary
public SpscGrowableArrayQueue(final int capacity)
SpscGrowableArrayQueueback to summary
public SpscGrowableArrayQueue(final int chunkSize, final int capacity)

Method Detail

adjustLookAheadStepback to summary
private void adjustLookAheadStep(int capacity)
capacityback to summary
public int capacity()

Implements io.netty.util.internal.shaded.org.jctools.queues.MessagePassingQueue.capacity, io.netty.util.internal.shaded.org.jctools.queues.IndexedQueueSizeUtil.IndexedQueue.capacity.

Returns:int

Doc from io.netty.util.internal.shaded.org.jctools.queues.MessagePassingQueue.capacity.

the capacity of this queue or MessagePassingQueue#UNBOUNDED_CAPACITY if not bounded

Annotations
@Override
offerColdPathback to summary
pack-priv final boolean offerColdPath(final E[] buffer, final long mask, final long index, final long offset, final E v, final MessagePassingQueue.Supplier<? extends E> s)

Implements abstract io.netty.util.internal.shaded.org.jctools.queues.BaseSpscLinkedArrayQueue.offerColdPath.

Annotations
@Override