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

Uses of MessagePassingQueue.Supplier in org.jctools.queues

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

Modifier and Type	Method and Description
int	MpscUnboundedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpmcArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpscArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpscLinkedQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscLinkedQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpmcArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	BaseMpscLinkedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscCompoundQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpmcArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
int	SpscArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
int	SpscLinkedQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
int	MpscLinkedQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
int	MpmcArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
int	BaseMpscLinkedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int batchSize)
int	MpscCompoundQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
int	MpscArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	SpmcArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition e)
void	SpscArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition e)
void	SpscLinkedQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
void	MpscLinkedQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
void	MpmcArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
void	BaseMpscLinkedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
void	MpscCompoundQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
void	MpscArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, 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.

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 and Description
int	SpscAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpscLinkedAtomicQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscUnboundedAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpmcAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpmcAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscLinkedAtomicQueue.fill(MessagePassingQueue.Supplier<E> s)
int	BaseMpscLinkedAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpscAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
int	SpscLinkedAtomicQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
int	MpscAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
int	MpmcAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
int	SpmcAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
int	MpscLinkedAtomicQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
int	BaseMpscLinkedAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int batchSize)
void	SpscAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition e)
void	SpscLinkedAtomicQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
void	MpscAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
void	MpmcAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
void	SpmcAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition e)
void	MpscLinkedAtomicQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
void	BaseMpscLinkedAtomicArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)