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

public Class MpscCompoundQueue<E>

Additional top-level classes in compilation unit: MpscCompoundQueueL0Pad, MpscCompoundQueueColdFields, MpscCompoundQueueMidPad, MpscCompoundQueueConsumerQueueIndex.

extends MpscCompoundQueueConsumerQueueIndex<E>
Class Inheritance
Imports
io.netty.util.internal.shaded.org.jctools.util.RangeUtil, java.util.AbstractQueue, .Iterator

Field Summary

Modifier and TypeField and Description
pack-priv byte
b000

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

pack-priv byte
b001

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

pack-priv byte
b002

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

pack-priv byte
b003

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

pack-priv byte
b004

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

pack-priv byte
b005

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

pack-priv byte
b006

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

pack-priv byte
b007

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

pack-priv byte
b010

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

pack-priv byte
b011

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

pack-priv byte
b012

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

pack-priv byte
b013

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

pack-priv byte
b014

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

pack-priv byte
b015

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

pack-priv byte
b016

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

pack-priv byte
b017

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

pack-priv byte
b020

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

pack-priv byte
b021

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

pack-priv byte
b022

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

pack-priv byte
b023

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

pack-priv byte
b024

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

pack-priv byte
b025

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

pack-priv byte
b026

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

pack-priv byte
b027

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

pack-priv byte
b030

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

pack-priv byte
b031

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

pack-priv byte
b032

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

pack-priv byte
b033

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

pack-priv byte
b034

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

pack-priv byte
b035

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

pack-priv byte
b036

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

pack-priv byte
b037

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

pack-priv byte
b040

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

pack-priv byte
b041

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

pack-priv byte
b042

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

pack-priv byte
b043

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

pack-priv byte
b044

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

pack-priv byte
b045

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

pack-priv byte
b046

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

pack-priv byte
b047

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

pack-priv byte
b050

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

pack-priv byte
b051

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

pack-priv byte
b052

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

pack-priv byte
b053

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

pack-priv byte
b054

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

pack-priv byte
b055

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

pack-priv byte
b056

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

pack-priv byte
b057

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

pack-priv byte
b060

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

pack-priv byte
b061

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

pack-priv byte
b062

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

pack-priv byte
b063

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

pack-priv byte
b064

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

pack-priv byte
b065

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

pack-priv byte
b066

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

pack-priv byte
b067

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

pack-priv byte
b070

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

pack-priv byte
b071

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

pack-priv byte
b072

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

pack-priv byte
b073

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

pack-priv byte
b074

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

pack-priv byte
b075

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

pack-priv byte
b076

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

pack-priv byte
b077

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

pack-priv byte
b100

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

pack-priv byte
b101

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

pack-priv byte
b102

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

pack-priv byte
b103

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

pack-priv byte
b104

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

pack-priv byte
b105

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

pack-priv byte
b106

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

pack-priv byte
b107

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

pack-priv byte
b110

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

pack-priv byte
b111

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

pack-priv byte
b112

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

pack-priv byte
b113

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

pack-priv byte
b114

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

pack-priv byte
b115

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

pack-priv byte
b116

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

pack-priv byte
b117

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

pack-priv byte
b120

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

pack-priv byte
b121

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

pack-priv byte
b122

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

pack-priv byte
b123

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

pack-priv byte
b124

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

pack-priv byte
b125

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

pack-priv byte
b126

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

pack-priv byte
b127

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

pack-priv byte
b130

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

pack-priv byte
b131

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

pack-priv byte
b132

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

pack-priv byte
b133

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

pack-priv byte
b134

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

pack-priv byte
b135

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

pack-priv byte
b136

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

pack-priv byte
b137

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

pack-priv byte
b140

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

pack-priv byte
b141

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

pack-priv byte
b142

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

pack-priv byte
b143

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

pack-priv byte
b144

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

pack-priv byte
b145

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

pack-priv byte
b146

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

pack-priv byte
b147

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

pack-priv byte
b150

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

pack-priv byte
b151

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

pack-priv byte
b152

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

pack-priv byte
b153

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

pack-priv byte
b154

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

pack-priv byte
b155

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

pack-priv byte
b156

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

pack-priv byte
b157

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

pack-priv byte
b160

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

pack-priv byte
b161

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

pack-priv byte
b162

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

pack-priv byte
b163

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

pack-priv byte
b164

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

pack-priv byte
b165

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

pack-priv byte
b166

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

pack-priv byte
b167

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

pack-priv byte
b170

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

pack-priv byte
b171

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

pack-priv byte
b172

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

pack-priv byte
b173

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

pack-priv byte
b174

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

pack-priv byte
b175

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

pack-priv byte
b176

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

pack-priv byte
b177

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

Inherited from io.netty.util.internal.shaded.org.jctools.queues.MpscCompoundQueueConsumerQueueIndex:
consumerQueueIndex

Constructor Summary

AccessConstructor and Description
public
MpscCompoundQueue(int capacity)

public
MpscCompoundQueue(int capacity, int queueParallelism)

Method Summary

Modifier and TypeMethod and Description
public int
capacity()

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

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(MessagePassingQueue.Consumer<E> c, 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 wait, 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
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 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 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 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.Queue.offer.

Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue#offer(Object) interface.
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()

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 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.
public 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 boolean
slowOffer(MpscArrayQueue<E>[] queues, int parallelQueuesMask, int start, E e)

public String
toString()

Overrides java.util.AbstractCollection.toString.

Returns a string representation of this collection.