Class MpscArrayConcurrentQueue<E>

java.lang.Object

org.jctools.queues.alt.ConcurrentCircularArray<E>

org.jctools.queues.alt.ConcurrentSequencedCircularArray<E>

org.jctools.queues.alt.MpscArrayConcurrentQueue<E>

All Implemented Interfaces:

ConcurrentQueue<E>

public final class MpscArrayConcurrentQueue<E>
extends ConcurrentSequencedCircularArray<E>
implements ConcurrentQueue<E>

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.jctools.queues.alt.MpscArrayConcurrentQueueColdFields.Consumer<E>	consumer
protected final org.jctools.queues.alt.MpscArrayConcurrentQueueColdFields.Producer<E>	producer

Fields inherited from class ConcurrentSequencedCircularArray

sequenceBuffer

Fields inherited from class ConcurrentCircularArray

buffer, BUFFER_PAD, mask, SPARSE_SHIFT

Constructor Summary

Constructors

Constructor	Description
MpscArrayConcurrentQueue(int capacity)

Method Summary

Modifier and Type	Method	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.

Methods inherited from class ConcurrentSequencedCircularArray

calcSequenceOffset, calcSequenceOffset, lpSequence, lpSequenceElement, lvSequence, lvSequence, soSequence, soSequenceElement, spSequenceElement, spSequenceElement, svSequenceElement, svSequenceElement

Methods inherited from class ConcurrentCircularArray

calcOffset, calcOffset, lpElement, lpElement, lvElement, lvElement, soElement, soElement, spElement, spElement, svElement, svElement

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

consumer

protected final org.jctools.queues.alt.MpscArrayConcurrentQueueColdFields.Consumer<E> consumer

producer

protected final org.jctools.queues.alt.MpscArrayConcurrentQueueColdFields.Producer<E> producer

Constructor Details

MpscArrayConcurrentQueue

public MpscArrayConcurrentQueue(int capacity)

Method Details

size

public int size()

Description copied from interface: ConcurrentQueue

This method may be O(n) or O(1) and may not be accurate.

Specified by:

size in interface ConcurrentQueue<E>

Returns:

the number of elements in the queue

capacity

public int capacity()

Specified by:

capacity in interface ConcurrentQueue<E>

Returns:

the maximum number of elements that can fit in this queue, or -1 if unbounded.

consumer

public ConcurrentQueueConsumer<E> consumer()

Specified by:

consumer in interface ConcurrentQueue<E>

Returns:

a consumer instance to be used from a consuming thread.

producer

public ConcurrentQueueProducer<E> producer()

Specified by:

producer in interface ConcurrentQueue<E>

Returns:

a producer instance to be used from a producing thread.