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	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	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)
static <E> int	MessagePassingQueueUtil.fillUnbounded(MessagePassingQueue<E> q, 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	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)

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	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)

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	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)