Note
This class was automatically generated by io.netty.util.internal.shaded.org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator
which can found in the jctools-build module. The original source file is SpscGrowableArrayQueue.java.
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.
| Modifier and Type | Field and Description |
|---|---|
| private long | |
| private final int |
| Access | Constructor and Description |
|---|---|
| public | |
| public |
| Modifier and Type | Method and Description |
|---|---|
| private void | |
| public int | |
| pack-priv final boolean | offerColdPath(final AtomicReferenceArray<E> buffer, final long mask, final long index, final int offset, final E v, final MessagePassingQueue.
Implements abstract io. |
| lookAheadStep | back to summary |
|---|---|
| private long lookAheadStep | |
| maxQueueCapacity | back to summary |
|---|---|
| private final int maxQueueCapacity | |
| SpscGrowableAtomicArrayQueue | back to summary |
|---|---|
| public SpscGrowableAtomicArrayQueue(final int capacity) | |
| SpscGrowableAtomicArrayQueue | back to summary |
|---|---|
| public SpscGrowableAtomicArrayQueue(final int chunkSize, final int capacity) | |
| adjustLookAheadStep | back to summary |
|---|---|
| private void adjustLookAheadStep(int capacity) | |
| capacity | back to summary |
|---|---|
| public int capacity() Implements io.
| |
| offerColdPath | back to summary |
|---|---|
| pack-priv final boolean offerColdPath(final AtomicReferenceArray<E> buffer, final long mask, final long index, final int offset, final E v, final MessagePassingQueue. Implements abstract io.
| |