Uses of Class
org.jctools.queues.MpscUnboundedXaddChunk

Packages that use MpscUnboundedXaddChunk

Package

Description

org.jctools.queues

This package aims to fill a gap in current JDK implementations in offering lock free (wait free where possible) queues for inter-thread message passing with finer grained guarantees and an emphasis on performance. At the time of writing the only lock free queue available in the JDK is ConcurrentLinkedQueue which is an unbounded multi-producer, multi-consumer queue which is further encumbered by the need to implement the full range of Queue methods.

Uses of MpscUnboundedXaddChunk in org.jctools.queues

Subclasses with type arguments of type MpscUnboundedXaddChunk in org.jctools.queues

Modifier and Type	Class	Description
class	MpscUnboundedXaddArrayQueue<E>	An MPSC array queue which grows unbounded in linked chunks. Differently from MpscUnboundedArrayQueue it is designed to provide a better scaling when more producers are concurrently offering. Users should be aware that MpscUnboundedXaddArrayQueue.poll() could spin while awaiting a new element to be available: to avoid this behaviour MpscUnboundedXaddArrayQueue.relaxedPoll() should be used instead, accounting for the semantic differences between the twos.
final class	MpscUnboundedXaddChunk<E>

Methods in org.jctools.queues that return MpscUnboundedXaddChunk

Modifier and Type	Method	Description
(package private) final MpscUnboundedXaddChunk<E>	MpscUnboundedXaddArrayQueue.newChunk(long index, MpscUnboundedXaddChunk<E> prev, int chunkSize, boolean pooled)
private MpscUnboundedXaddChunk<E>	MpscUnboundedXaddArrayQueue.pollNextBuffer(MpscUnboundedXaddChunk<E> cChunk, long cIndex)
private MpscUnboundedXaddChunk<E>	MpscUnboundedXaddArrayQueue.spinForNextIfNotEmpty(MpscUnboundedXaddChunk<E> cChunk, long cIndex)

Methods in org.jctools.queues with parameters of type MpscUnboundedXaddChunk

Modifier and Type	Method	Description
(package private) final MpscUnboundedXaddChunk<E>	MpscUnboundedXaddArrayQueue.newChunk(long index, MpscUnboundedXaddChunk<E> prev, int chunkSize, boolean pooled)
private MpscUnboundedXaddChunk<E>	MpscUnboundedXaddArrayQueue.pollNextBuffer(MpscUnboundedXaddChunk<E> cChunk, long cIndex)
private MpscUnboundedXaddChunk<E>	MpscUnboundedXaddArrayQueue.spinForNextIfNotEmpty(MpscUnboundedXaddChunk<E> cChunk, long cIndex)

Constructors in org.jctools.queues with parameters of type MpscUnboundedXaddChunk

Modifier	Constructor	Description
	MpscUnboundedXaddChunk(long index, MpscUnboundedXaddChunk<E> prev, int size, boolean pooled)