public final class SpscArrayConcurrentQueue<E> extends ConcurrentCircularArray<E> implements ConcurrentQueue<E>
Modifier and Type | Field and Description |
---|---|
protected org.jctools.queues.alt.Consumer<E> |
consumer |
protected static int |
OFFER_BATCH_SIZE |
protected org.jctools.queues.alt.Producer<E> |
producer |
buffer, BUFFER_PAD, mask, SPARSE_SHIFT
Constructor and Description |
---|
SpscArrayConcurrentQueue(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.
|
calcOffset, calcOffset, lpElement, lpElement, lvElement, lvElement, soElement, soElement, spElement, spElement, svElement, svElement
protected static final int OFFER_BATCH_SIZE
protected final org.jctools.queues.alt.Consumer<E> consumer
protected final org.jctools.queues.alt.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–2018. All rights reserved.