public final class MpmcArrayConcurrentQueue<E> extends MpmcArrayConcurrentQueueColdFields<E> implements ConcurrentQueue<E>
MpmcArrayConcurrentQueueColdFields.Consumer<E>, MpmcArrayConcurrentQueueColdFields.Producer<E>
Modifier and Type | Field and Description |
---|---|
(package private) long |
p00 |
(package private) long |
p01 |
(package private) long |
p02 |
(package private) long |
p03 |
(package private) long |
p04 |
(package private) long |
p05 |
(package private) long |
p06 |
(package private) long |
p07 |
(package private) long |
p10 |
(package private) long |
p11 |
(package private) long |
p12 |
(package private) long |
p13 |
(package private) long |
p14 |
(package private) long |
p15 |
(package private) long |
p16 |
(package private) long |
p17 |
consumer, producer
sequenceBuffer
buffer, BUFFER_PAD, mask, SPARSE_SHIFT
Constructor and Description |
---|
MpmcArrayConcurrentQueue(int capacity) |
Modifier and Type | Method and Description |
---|---|
int |
capacity() |
ConcurrentQueueConsumer<E> |
consumer() |
ConcurrentQueueProducer<E> |
producer() |
int |
size()
This method may be O(n) or O(1) and may not be accurate.
|
calcSequenceOffset, calcSequenceOffset, lpSequence, lpSequenceElement, lvSequence, lvSequence, soSequence, soSequenceElement, spSequenceElement, spSequenceElement, svSequenceElement, svSequenceElement
calcOffset, calcOffset, lpElement, lpElement, lvElement, lvElement, soElement, soElement, spElement, spElement, svElement, svElement
long p00
long p01
long p02
long p03
long p04
long p05
long p06
long p07
long p10
long p11
long p12
long p13
long p14
long p15
long p16
long p17
public int size()
ConcurrentQueue
size
in interface ConcurrentQueue<E>
public int capacity()
capacity
in interface ConcurrentQueue<E>
public ConcurrentQueueConsumer<E> consumer()
consumer
in interface ConcurrentQueue<E>
public ConcurrentQueueProducer<E> producer()
producer
in interface ConcurrentQueue<E>