Uses of Interface
org.jctools.queues.MessagePassingQueue.Supplier

Packages that use MessagePassingQueue.Supplier

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.
org.jctools.queues.atomic
org.jctools.queues.atomic.unpadded
org.jctools.queues.unpadded

Uses of MessagePassingQueue.Supplier in org.jctools.queues

Methods in org.jctools.queues with parameters of type MessagePassingQueue.Supplier

Modifier and Type	Method	Description
int	BaseMpscLinkedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	BaseMpscLinkedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	BaseMpscLinkedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	BaseSpscLinkedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	BaseSpscLinkedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	BaseSpscLinkedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	FFBuffer.fill(MessagePassingQueue.Supplier<E> s)
int	FFBuffer.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	FFBuffer.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MessagePassingQueue.fill(MessagePassingQueue.Supplier<T> s)	Stuff the queue with elements from the supplier.
int	MessagePassingQueue.fill(MessagePassingQueue.Supplier<T> s, int limit)	Stuff the queue with up to limit elements from the supplier.
void	MessagePassingQueue.fill(MessagePassingQueue.Supplier<T> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)	Stuff the queue with elements from the supplier forever.
static <E> void	MessagePassingQueueUtil.fill(MessagePassingQueue<E> q, MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpmcArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpmcArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpmcArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpmcUnboundedXaddArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
int	MpscArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpscArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpscBlockingConsumerArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscBlockingConsumerArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpscBlockingConsumerArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpscCompoundQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscCompoundQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpscCompoundQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpscLinkedQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscLinkedQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpscLinkedQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpscRelaxedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscRelaxedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpscRelaxedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	MpscSequencedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscSequencedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpscSequencedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpscUnboundedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscUnboundedXaddArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscUnboundedXaddArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
int	MpUnboundedXaddArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
void	MpUnboundedXaddArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	SpmcArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpmcArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	SpmcArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition e)
int	SpscArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpscArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	SpscArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition e)
int	SpscLinkedQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpscLinkedQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	SpscLinkedQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	SpscUnboundedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
static <E> int	MessagePassingQueueUtil.fillBounded(MessagePassingQueue<E> q, MessagePassingQueue.Supplier<E> s)
static <E> int	MessagePassingQueueUtil.fillInBatchesToLimit(MessagePassingQueue<E> q, MessagePassingQueue.Supplier<E> s, int batch, int limit)
private int	MpmcArrayQueue.fillOneByOne(MessagePassingQueue.Supplier<E> s, int limit)
static <E> int	MessagePassingQueueUtil.fillUnbounded(MessagePassingQueue<E> q, MessagePassingQueue.Supplier<E> s)
(package private) abstract boolean	BaseSpscLinkedArrayQueue.offerColdPath(E[] buffer, long mask, long pIndex, long offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) final boolean	SpscChunkedArrayQueue.offerColdPath(E[] buffer, long mask, long pIndex, long offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) final boolean	SpscGrowableArrayQueue.offerColdPath(E[] buffer, long mask, long index, long offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) final boolean	SpscUnboundedArrayQueue.offerColdPath(E[] buffer, long mask, long pIndex, long offset, E v, MessagePassingQueue.Supplier<? extends E> s)
private void	BaseMpscLinkedArrayQueue.resize(long oldMask, E[] oldBuffer, long pIndex, E e, MessagePassingQueue.Supplier<E> s)

Uses of MessagePassingQueue.Supplier in org.jctools.queues.atomic

Methods in org.jctools.queues.atomic with parameters of type MessagePassingQueue.Supplier

Modifier and Type	Method	Description
int	BaseMpscLinkedAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	BaseMpscLinkedAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	BaseMpscLinkedAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	BaseSpscLinkedAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	BaseSpscLinkedAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	BaseSpscLinkedAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpmcAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpmcAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpmcAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpscAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpscAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpscLinkedAtomicQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscLinkedAtomicQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpscLinkedAtomicQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpscRelaxedAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscRelaxedAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpscRelaxedAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	MpscUnboundedAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpmcAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpmcAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	SpmcAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition e)
int	SpscAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpscAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	SpscAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition e)
int	SpscLinkedAtomicQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpscLinkedAtomicQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	SpscLinkedAtomicQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	SpscUnboundedAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
private int	MpmcAtomicArrayQueue.fillOneByOne(MessagePassingQueue.Supplier<E> s, int limit)
(package private) abstract boolean	BaseSpscLinkedAtomicArrayQueue.offerColdPath(AtomicReferenceArray<E> buffer, long mask, long pIndex, int offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) final boolean	SpscChunkedAtomicArrayQueue.offerColdPath(AtomicReferenceArray<E> buffer, long mask, long pIndex, int offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) final boolean	SpscGrowableAtomicArrayQueue.offerColdPath(AtomicReferenceArray<E> buffer, long mask, long index, int offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) final boolean	SpscUnboundedAtomicArrayQueue.offerColdPath(AtomicReferenceArray<E> buffer, long mask, long pIndex, int offset, E v, MessagePassingQueue.Supplier<? extends E> s)
private void	BaseMpscLinkedAtomicArrayQueue.resize(long oldMask, AtomicReferenceArray<E> oldBuffer, long pIndex, E e, MessagePassingQueue.Supplier<E> s)

Uses of MessagePassingQueue.Supplier in org.jctools.queues.atomic.unpadded

Methods in org.jctools.queues.atomic.unpadded with parameters of type MessagePassingQueue.Supplier

Modifier and Type	Method	Description
int	BaseMpscLinkedAtomicUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	BaseMpscLinkedAtomicUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	BaseMpscLinkedAtomicUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	BaseSpscLinkedAtomicUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	BaseSpscLinkedAtomicUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	BaseSpscLinkedAtomicUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpmcAtomicUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpmcAtomicUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpmcAtomicUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpscAtomicUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscAtomicUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpscAtomicUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpscLinkedAtomicUnpaddedQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscLinkedAtomicUnpaddedQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpscLinkedAtomicUnpaddedQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpscUnboundedAtomicUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpmcAtomicUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpmcAtomicUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	SpmcAtomicUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition e)
int	SpscAtomicUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpscAtomicUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	SpscAtomicUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition e)
int	SpscLinkedAtomicUnpaddedQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpscLinkedAtomicUnpaddedQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	SpscLinkedAtomicUnpaddedQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	SpscUnboundedAtomicUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
private int	MpmcAtomicUnpaddedArrayQueue.fillOneByOne(MessagePassingQueue.Supplier<E> s, int limit)
(package private) abstract boolean	BaseSpscLinkedAtomicUnpaddedArrayQueue.offerColdPath(AtomicReferenceArray<E> buffer, long mask, long pIndex, int offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) final boolean	SpscChunkedAtomicUnpaddedArrayQueue.offerColdPath(AtomicReferenceArray<E> buffer, long mask, long pIndex, int offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) final boolean	SpscGrowableAtomicUnpaddedArrayQueue.offerColdPath(AtomicReferenceArray<E> buffer, long mask, long index, int offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) final boolean	SpscUnboundedAtomicUnpaddedArrayQueue.offerColdPath(AtomicReferenceArray<E> buffer, long mask, long pIndex, int offset, E v, MessagePassingQueue.Supplier<? extends E> s)
private void	BaseMpscLinkedAtomicUnpaddedArrayQueue.resize(long oldMask, AtomicReferenceArray<E> oldBuffer, long pIndex, E e, MessagePassingQueue.Supplier<E> s)

Uses of MessagePassingQueue.Supplier in org.jctools.queues.unpadded

Methods in org.jctools.queues.unpadded with parameters of type MessagePassingQueue.Supplier

Modifier and Type	Method	Description
int	BaseMpscLinkedUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	BaseMpscLinkedUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	BaseMpscLinkedUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	BaseSpscLinkedUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	BaseSpscLinkedUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	BaseSpscLinkedUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpmcUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpmcUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpmcUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpscLinkedUnpaddedQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscLinkedUnpaddedQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpscLinkedUnpaddedQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpscUnboundedUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpscUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	SpmcUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpmcUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	SpmcUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition e)
int	SpscLinkedUnpaddedQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpscLinkedUnpaddedQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	SpscLinkedUnpaddedQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	SpscUnboundedUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpscUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpscUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	SpscUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition e)
private int	MpmcUnpaddedArrayQueue.fillOneByOne(MessagePassingQueue.Supplier<E> s, int limit)
(package private) abstract boolean	BaseSpscLinkedUnpaddedArrayQueue.offerColdPath(E[] buffer, long mask, long pIndex, long offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) final boolean	SpscChunkedUnpaddedArrayQueue.offerColdPath(E[] buffer, long mask, long pIndex, long offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) final boolean	SpscGrowableUnpaddedArrayQueue.offerColdPath(E[] buffer, long mask, long index, long offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) final boolean	SpscUnboundedUnpaddedArrayQueue.offerColdPath(E[] buffer, long mask, long pIndex, long offset, E v, MessagePassingQueue.Supplier<? extends E> s)
private void	BaseMpscLinkedUnpaddedArrayQueue.resize(long oldMask, E[] oldBuffer, long pIndex, E e, MessagePassingQueue.Supplier<E> s)