Class SpscArrayConcurrentQueue<E>

java.lang.Object

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

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

All Implemented Interfaces:

ConcurrentQueue<E>

public final class SpscArrayConcurrentQueue<E>
extends ConcurrentCircularArray<E>
implements ConcurrentQueue<E>

Field Summary

Fields

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

Fields inherited from class ConcurrentCircularArray

buffer, BUFFER_PAD, mask, SPARSE_SHIFT

Constructor Summary

Constructors

Constructor	Description
SpscArrayConcurrentQueue(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 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

OFFER_BATCH_SIZE

protected static final int OFFER_BATCH_SIZE

consumer

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

producer

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

Constructor Details

SpscArrayConcurrentQueue

public SpscArrayConcurrentQueue(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.