public final class MpmcArrayConcurrentQueue<E> extends ConcurrentSequencedCircularArray<E> implements ConcurrentQueue<E>
Modifier and Type | Field and Description |
---|---|
protected org.jctools.queues.alt.MpmcArrayConcurrentQueueColdFields.Consumer<E> |
consumer |
protected org.jctools.queues.alt.MpmcArrayConcurrentQueueColdFields.Producer<E> |
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
protected final org.jctools.queues.alt.MpmcArrayConcurrentQueueColdFields.Consumer<E> consumer
protected final org.jctools.queues.alt.MpmcArrayConcurrentQueueColdFields.Producer<E> producer
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>
Copyright © 2013–2020. All rights reserved.