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

public Class MpscBlockingConsumerArrayQueue<E>

Additional top-level classes in compilation unit: MpscBlockingConsumerArrayQueuePad1, MpscBlockingConsumerArrayQueueColdProducerFields, MpscBlockingConsumerArrayQueuePad2, MpscBlockingConsumerArrayQueueProducerFields, MpscBlockingConsumerArrayQueuePad3, MpscBlockingConsumerArrayQueueConsumerFields.

extends MpscBlockingConsumerArrayQueueConsumerFields<E>
implements MessagePassingQueue<E>, QueueProgressIndicators, BlockingQueue<E>
Class Inheritance
All Implemented Interfaces
java.util.concurrent.BlockingQueue, java.util.Queue, java.util.Collection, java.lang.Iterable, io.netty.util.internal.shaded.org.jctools.queues.QueueProgressIndicators, io.netty.util.internal.shaded.org.jctools.queues.MessagePassingQueue
Annotations
@SuppressWarnings:unused
Imports
java.util.AbstractQueue, .Collection, .Iterator, java.util.concurrent.BlockingQueue, .TimeUnit, java.util.concurrent.locks.LockSupport, io.netty.util.internal.shaded.org.jctools.queues.IndexedQueueSizeUtil.IndexedQueue, io.netty.util.internal.shaded.org.jctools.util.Pow2, .RangeUtil
This is a partial implementation of the java.util.concurrent.BlockingQueue on the consumer side only on top of the mechanics described in BaseMpscLinkedArrayQueue, but with the reservation bit used for blocking rather than resizing in this instance.

Field Summary

Modifier and TypeField and Description
pack-priv byte
b000

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

pack-priv byte
b001

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

pack-priv byte
b002

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

pack-priv byte
b003

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

pack-priv byte
b004

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

pack-priv byte
b005

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

pack-priv byte
b006

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

pack-priv byte
b007

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

pack-priv byte
b010

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

pack-priv byte
b011

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

pack-priv byte
b012

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

pack-priv byte
b013

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

pack-priv byte
b014

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

pack-priv byte
b015

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

pack-priv byte
b016

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

pack-priv byte
b017

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

pack-priv byte
b020

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

pack-priv byte
b021

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

pack-priv byte
b022

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

pack-priv byte
b023

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

pack-priv byte
b024

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

pack-priv byte
b025

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

pack-priv byte
b026

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

pack-priv byte
b027

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

pack-priv byte
b030

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

pack-priv byte
b031

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

pack-priv byte
b032

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

pack-priv byte
b033

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

pack-priv byte
b034

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

pack-priv byte
b035

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

pack-priv byte
b036

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

pack-priv byte
b037

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

pack-priv byte
b040

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

pack-priv byte
b041

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

pack-priv byte
b042

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

pack-priv byte
b043

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

pack-priv byte
b044

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

pack-priv byte
b045

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

pack-priv byte
b046

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

pack-priv byte
b047

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

pack-priv byte
b050

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

pack-priv byte
b051

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

pack-priv byte
b052

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

pack-priv byte
b053

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

pack-priv byte
b054

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

pack-priv byte
b055

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

pack-priv byte
b056

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

pack-priv byte
b057

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

pack-priv byte
b060

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

pack-priv byte
b061

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

pack-priv byte
b062

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

pack-priv byte
b063

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

pack-priv byte
b064

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

pack-priv byte
b065

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

pack-priv byte
b066

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

pack-priv byte
b067

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

pack-priv byte
b070

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

pack-priv byte
b071

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

pack-priv byte
b072

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

pack-priv byte
b073

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

pack-priv byte
b074

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

pack-priv byte
b075

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

pack-priv byte
b076

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

pack-priv byte
b077

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

pack-priv byte
b100

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

pack-priv byte
b101

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

pack-priv byte
b102

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

pack-priv byte
b103

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

pack-priv byte
b104

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

pack-priv byte
b105

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

pack-priv byte
b106

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

pack-priv byte
b107

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

pack-priv byte
b110

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

pack-priv byte
b111

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

pack-priv byte
b112

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

pack-priv byte
b113

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

pack-priv byte
b114

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

pack-priv byte
b115

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

pack-priv byte
b116

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

pack-priv byte
b117

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

pack-priv byte
b120

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

pack-priv byte
b121

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

pack-priv byte
b122

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

pack-priv byte
b123

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

pack-priv byte
b124

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

pack-priv byte
b125

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

pack-priv byte
b126

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

pack-priv byte
b127

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

pack-priv byte
b130

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

pack-priv byte
b131

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

pack-priv byte
b132

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

pack-priv byte
b133

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

pack-priv byte
b134

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

pack-priv byte
b135

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

pack-priv byte
b136

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

pack-priv byte
b137

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

pack-priv byte
b140

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

pack-priv byte
b141

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

pack-priv byte
b142

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

pack-priv byte
b143

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

pack-priv byte
b144

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

pack-priv byte
b145

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

pack-priv byte
b146

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

pack-priv byte
b147

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

pack-priv byte
b150

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

pack-priv byte
b151

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

pack-priv byte
b152

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

pack-priv byte
b153

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

pack-priv byte
b154

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

pack-priv byte
b155

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

pack-priv byte
b156

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

pack-priv byte
b157

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

pack-priv byte
b160

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

pack-priv byte
b161

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

pack-priv byte
b162

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

pack-priv byte
b163

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

pack-priv byte
b164

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

pack-priv byte
b165

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

pack-priv byte
b166

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

pack-priv byte
b167

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

pack-priv byte
b170

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

pack-priv byte
b171

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

pack-priv byte
b172

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

pack-priv byte
b173

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

pack-priv byte
b174

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

pack-priv byte
b175

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

pack-priv byte
b176

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

pack-priv byte
b177

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

Inherited from io.netty.util.internal.shaded.org.jctools.queues.MpscBlockingConsumerArrayQueueConsumerFields:
consumerBufferconsumerMask

Constructor Summary

AccessConstructor and Description
public
MpscBlockingConsumerArrayQueue(final int capacity)

Method Summary

Modifier and TypeMethod and Description
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.

public long
currentConsumerIndex()

Implements io.netty.util.internal.shaded.org.jctools.queues.QueueProgressIndicators.currentConsumerIndex.

This method has no concurrent visibility semantics.
public long
currentProducerIndex()

Implements io.netty.util.internal.shaded.org.jctools.queues.QueueProgressIndicators.currentProducerIndex.

This method has no concurrent visibility semantics.
public int
drain(MessagePassingQueue.Consumer<E> c)

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

Remove all available item from the queue and hand to consume.
public int
drain(final MessagePassingQueue.Consumer<E> c, final int limit)

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

Remove up to limit elements from the queue and hand to consume.
public void
drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)

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

Remove elements from the queue and hand to consume forever.
public int
drainTo(Collection<? super E>
the collection to transfer elements into
c)

Implements java.util.concurrent.BlockingQueue.drainTo.

Removes all available elements from this queue and adds them to the given collection.
public int
drainTo(Collection<? super E>
the collection to transfer elements into
c, int
the maximum number of elements to transfer
maxElements)

Implements java.util.concurrent.BlockingQueue.drainTo.

Removes at most the given number of available elements from this queue and adds them to the given collection.
public int
fill(MessagePassingQueue.Supplier<E> s, int limit)

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

Stuff the queue with up to limit elements from the supplier.
public int
fill(MessagePassingQueue.Supplier<E> s)

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

Stuff the queue with elements from the supplier.
public void
fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)

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

Stuff the queue with elements from the supplier forever.
public final boolean
isEmpty()

Overrides java.util.AbstractCollection.isEmpty.

Implements io.netty.util.internal.shaded.org.jctools.queues.MessagePassingQueue.isEmpty, java.util.Collection.isEmpty.

This method's accuracy is subject to concurrent modifications happening as the observation is carried out.
public final Iterator<E>
iterator()

Implements abstract java.util.AbstractCollection.iterator.

Implements java.util.Collection.iterator.

Returns an iterator over the elements in this collection.
public boolean
offer(final E
not null, will throw NPE if it is
e)

Implements io.netty.util.internal.shaded.org.jctools.queues.MessagePassingQueue.offer, java.util.concurrent.BlockingQueue.offer, java.util.Queue.offer.

Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue#offer(Object) interface.
public boolean
offer(E
the element to add
e, long
how long to wait before giving up, in units of unit
timeout, TimeUnit
a TimeUnit determining how to interpret the timeout parameter
unit)

Implements java.util.concurrent.BlockingQueue.offer.

Inserts the specified element into this queue, waiting up to the specified wait time if necessary for space to become available.
private boolean
offerAndWakeup(E[] buffer, long mask, long pIndex, E e)

public boolean

Returns:

true if the offer is successful, false if queue size exceeds threshold
offerIfBelowThreshold(final E
the object to offer onto the queue, not null
e, int
the maximum allowable size
threshold)

offer if size() is less than threshold.

private E
parkUntilNext(E[] buffer, long cIndex, long offset, long timeoutNs)

public E
peek()

Implements io.netty.util.internal.shaded.org.jctools.queues.MessagePassingQueue.peek, java.util.Queue.peek.

Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue#peek() interface.
public E
poll(long
how long to wait before giving up, in units of unit
timeout, TimeUnit
a TimeUnit determining how to interpret the timeout parameter
unit)

Implements java.util.concurrent.BlockingQueue.poll.

Retrieves and removes the head of this queue, waiting up to the specified wait time if necessary for an element to become available.
public E
poll()

Implements io.netty.util.internal.shaded.org.jctools.queues.MessagePassingQueue.poll, java.util.Queue.poll.

Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue#poll() interface.
public void
put(E
the element to add
e)

Implements java.util.concurrent.BlockingQueue.put.

Inserts the specified element into this queue, waiting if necessary for space to become available.
private boolean
recalculateProducerLimit(long mask, long pIndex, long producerLimit)

private boolean
recalculateProducerLimit(long pIndex, long producerLimit, long cIndex, long bufferCapacity, long threshold)

public boolean
relaxedOffer(E
not null, will throw NPE if it is
e)

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

Called from a producer thread subject to the restrictions appropriate to the implementation.
public E
relaxedPeek()

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

Called from the consumer thread subject to the restrictions appropriate to the implementation.
public E
relaxedPoll()

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

Called from the consumer thread subject to the restrictions appropriate to the implementation.
private void
releaseParkedConsumer(Thread consumerThread)

A consumer is trapped in `parking` until the field is nulled, and this code can only be executed after it is no longer in that state.

public int
remainingCapacity()

Implements java.util.concurrent.BlockingQueue.remainingCapacity.

Returns the number of additional elements that this queue can ideally (in the absence of memory or resource constraints) accept without blocking, or Integer.MAX_VALUE if there is no intrinsic limit.
private boolean
revertParkedState(long pIndex)

Consumer must revert the `parked` state when interrupted or thewhen returning after a timeout.

public final int
size()

Implements abstract java.util.AbstractCollection.size.

Implements io.netty.util.internal.shaded.org.jctools.queues.MessagePassingQueue.size, java.util.Collection.size.

This method's accuracy is subject to concurrent modifications happening as the size is estimated and as such is a best effort rather than absolute value.
private static <E> E
spinWaitForElement(E[] buffer, long offset)

private void
spinWaitForUnblock()

public E
take()

Implements java.util.concurrent.BlockingQueue.take.

Retrieves and removes the head of this queue, waiting if necessary until an element becomes available.
public String
toString()

Overrides java.util.AbstractCollection.toString.

Returns a string representation of this collection.
private void
wakeupConsumer()

Inherited from io.netty.util.internal.shaded.org.jctools.queues.MpscBlockingConsumerArrayQueueConsumerFields:
lpConsumerIndexlvBlockedlvConsumerIndexsoBlockedsoConsumerIndex