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 SpscChunkedArrayQueue.java.
An SPSC array queue which starts at initialCapacity and grows to maxCapacity 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.
| Modifier and Type | Field and Description |
|---|---|
| private final int | |
| private long |
| Access | Constructor and Description |
|---|---|
| public | |
| public |
| Modifier and Type | Method and Description |
|---|---|
| public int | |
| pack-priv final boolean | offerColdPath(AtomicReferenceArray<E> buffer, long mask, long pIndex, int offset, E v, MessagePassingQueue.
Implements abstract io. |
| maxQueueCapacity | back to summary |
|---|---|
| private final int maxQueueCapacity | |
| producerQueueLimit | back to summary |
|---|---|
| private long producerQueueLimit | |
| SpscChunkedAtomicArrayQueue | back to summary |
|---|---|
| public SpscChunkedAtomicArrayQueue(int capacity) | |
| SpscChunkedAtomicArrayQueue | back to summary |
|---|---|
| public SpscChunkedAtomicArrayQueue(int chunkSize, int capacity) | |
| capacity | back to summary |
|---|---|
| public int capacity() Implements io.
| |
| offerColdPath | back to summary |
|---|---|
| pack-priv final boolean offerColdPath(AtomicReferenceArray<E> buffer, long mask, long pIndex, int offset, E v, MessagePassingQueue. Implements abstract io.
| |