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

public Class MpscUnboundedArrayQueue<E>

extends BaseMpscLinkedArrayQueue<E>
Class Inheritance
Static Imports
io.netty.util.internal.shaded.org.jctools.queues.LinkedArrayQueueUtil.length
An MPSC 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.

Field Summary

Modifier and TypeField and Description
pack-priv byte
b000

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b000.

pack-priv byte
b001

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b001.

pack-priv byte
b002

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b002.

pack-priv byte
b003

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b003.

pack-priv byte
b004

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b004.

pack-priv byte
b005

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b005.

pack-priv byte
b006

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b006.

pack-priv byte
b007

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b007.

pack-priv byte
b010

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b010.

pack-priv byte
b011

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b011.

pack-priv byte
b012

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b012.

pack-priv byte
b013

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b013.

pack-priv byte
b014

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b014.

pack-priv byte
b015

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b015.

pack-priv byte
b016

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b016.

pack-priv byte
b017

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b017.

pack-priv byte
b020

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b020.

pack-priv byte
b021

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b021.

pack-priv byte
b022

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b022.

pack-priv byte
b023

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b023.

pack-priv byte
b024

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b024.

pack-priv byte
b025

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b025.

pack-priv byte
b026

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b026.

pack-priv byte
b027

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b027.

pack-priv byte
b030

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b030.

pack-priv byte
b031

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b031.

pack-priv byte
b032

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b032.

pack-priv byte
b033

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b033.

pack-priv byte
b034

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b034.

pack-priv byte
b035

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b035.

pack-priv byte
b036

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b036.

pack-priv byte
b037

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b037.

pack-priv byte
b040

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b040.

pack-priv byte
b041

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b041.

pack-priv byte
b042

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b042.

pack-priv byte
b043

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b043.

pack-priv byte
b044

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b044.

pack-priv byte
b045

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b045.

pack-priv byte
b046

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b046.

pack-priv byte
b047

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b047.

pack-priv byte
b050

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b050.

pack-priv byte
b051

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b051.

pack-priv byte
b052

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b052.

pack-priv byte
b053

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b053.

pack-priv byte
b054

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b054.

pack-priv byte
b055

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b055.

pack-priv byte
b056

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b056.

pack-priv byte
b057

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b057.

pack-priv byte
b060

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b060.

pack-priv byte
b061

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b061.

pack-priv byte
b062

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b062.

pack-priv byte
b063

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b063.

pack-priv byte
b064

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b064.

pack-priv byte
b065

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b065.

pack-priv byte
b066

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b066.

pack-priv byte
b067

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b067.

pack-priv byte
b070

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b070.

pack-priv byte
b071

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b071.

pack-priv byte
b072

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b072.

pack-priv byte
b073

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b073.

pack-priv byte
b074

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b074.

pack-priv byte
b075

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b075.

pack-priv byte
b076

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b076.

pack-priv byte
b077

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b077.

pack-priv byte
b100

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b100.

pack-priv byte
b101

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b101.

pack-priv byte
b102

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b102.

pack-priv byte
b103

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b103.

pack-priv byte
b104

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b104.

pack-priv byte
b105

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b105.

pack-priv byte
b106

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b106.

pack-priv byte
b107

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b107.

pack-priv byte
b110

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b110.

pack-priv byte
b111

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b111.

pack-priv byte
b112

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b112.

pack-priv byte
b113

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b113.

pack-priv byte
b114

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b114.

pack-priv byte
b115

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b115.

pack-priv byte
b116

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b116.

pack-priv byte
b117

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b117.

pack-priv byte
b120

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b120.

pack-priv byte
b121

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b121.

pack-priv byte
b122

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b122.

pack-priv byte
b123

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b123.

pack-priv byte
b124

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b124.

pack-priv byte
b125

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b125.

pack-priv byte
b126

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b126.

pack-priv byte
b127

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b127.

pack-priv byte
b130

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b130.

pack-priv byte
b131

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b131.

pack-priv byte
b132

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b132.

pack-priv byte
b133

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b133.

pack-priv byte
b134

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b134.

pack-priv byte
b135

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b135.

pack-priv byte
b136

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b136.

pack-priv byte
b137

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b137.

pack-priv byte
b140

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b140.

pack-priv byte
b141

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b141.

pack-priv byte
b142

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b142.

pack-priv byte
b143

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b143.

pack-priv byte
b144

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b144.

pack-priv byte
b145

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b145.

pack-priv byte
b146

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b146.

pack-priv byte
b147

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b147.

pack-priv byte
b150

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b150.

pack-priv byte
b151

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b151.

pack-priv byte
b152

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b152.

pack-priv byte
b153

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b153.

pack-priv byte
b154

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b154.

pack-priv byte
b155

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b155.

pack-priv byte
b156

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b156.

pack-priv byte
b157

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b157.

pack-priv byte
b160

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b160.

pack-priv byte
b161

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b161.

pack-priv byte
b162

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b162.

pack-priv byte
b163

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b163.

pack-priv byte
b164

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b164.

pack-priv byte
b165

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b165.

pack-priv byte
b166

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b166.

pack-priv byte
b167

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b167.

pack-priv byte
b170

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b170.

pack-priv byte
b171

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b171.

pack-priv byte
b172

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b172.

pack-priv byte
b173

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b173.

pack-priv byte
b174

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b174.

pack-priv byte
b175

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b175.

pack-priv byte
b176

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b176.

pack-priv byte
b177

Hides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueuePad3.b177.

Constructor Summary

AccessConstructor and Description
public
MpscUnboundedArrayQueue(int chunkSize)

Method Summary

Modifier and TypeMethod and Description
protected long
availableInQueue(long pIndex, long cIndex)

Implements abstract io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueue.availableInQueue.

public int
capacity()

Implements abstract io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueue.capacity.

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

public int
drain(MessagePassingQueue.Consumer<E> c)

Overrides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueue.drain.

Implements io.netty.util.internal.shaded.org.jctools.queues.MessagePassingQueue.drain.

Remove all available item from the queue and hand to consume.
public int
fill(MessagePassingQueue.Supplier<E> s)

Overrides io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueue.fill.

Implements io.netty.util.internal.shaded.org.jctools.queues.MessagePassingQueue.fill.

Stuff the queue with elements from the supplier.
protected long
getCurrentBufferCapacity(long mask)

Implements abstract io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueue.getCurrentBufferCapacity.

protected int
getNextBufferSize(E[] buffer)

Implements abstract io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueue.getNextBufferSize.

Inherited from io.netty.util.internal.shaded.org.jctools.queues.BaseMpscLinkedArrayQueue:
currentConsumerIndexcurrentProducerIndexdraindrainfillfillisEmptyiteratorofferpeekpollrelaxedOfferrelaxedPeekrelaxedPollsizetoString