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	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	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	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) boolean	SpscChunkedArrayQueue.offerColdPath(E[] buffer, long mask, long pIndex, long offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) boolean	SpscGrowableArrayQueue.offerColdPath(E[] buffer, long mask, long index, long offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) 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	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(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, long mask, long pIndex, int offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) boolean	SpscChunkedAtomicArrayQueue.offerColdPath(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, long mask, long pIndex, int offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) boolean	SpscGrowableAtomicArrayQueue.offerColdPath(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, long mask, long index, int offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) boolean	SpscUnboundedAtomicArrayQueue.offerColdPath(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, long mask, long pIndex, int offset, E v, MessagePassingQueue.Supplier<? extends E> s)
private void	BaseMpscLinkedAtomicArrayQueue.resize(long oldMask, java.util.concurrent.atomic.AtomicReferenceArray<E> oldBuffer, long pIndex, E e, MessagePassingQueue.Supplier<E> s)