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
org.jctools.queues.varhandle
org.jctools.queues.varhandle.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) 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	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(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)

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(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, long mask, long pIndex, int offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) boolean	SpscChunkedAtomicUnpaddedArrayQueue.offerColdPath(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, long mask, long pIndex, int offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) boolean	SpscGrowableAtomicUnpaddedArrayQueue.offerColdPath(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, long mask, long index, int offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) boolean	SpscUnboundedAtomicUnpaddedArrayQueue.offerColdPath(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, long mask, long pIndex, int offset, E v, MessagePassingQueue.Supplier<? extends E> s)
private void	BaseMpscLinkedAtomicUnpaddedArrayQueue.resize(long oldMask, java.util.concurrent.atomic.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) boolean	SpscChunkedUnpaddedArrayQueue.offerColdPath(E[] buffer, long mask, long pIndex, long offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) boolean	SpscGrowableUnpaddedArrayQueue.offerColdPath(E[] buffer, long mask, long index, long offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) 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)

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

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

Modifier and Type	Method	Description
int	BaseMpscLinkedVarHandleArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	BaseMpscLinkedVarHandleArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	BaseMpscLinkedVarHandleArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	BaseSpscLinkedVarHandleArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	BaseSpscLinkedVarHandleArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	BaseSpscLinkedVarHandleArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpmcVarHandleArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpmcVarHandleArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpmcVarHandleArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpscBlockingConsumerVarHandleArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscBlockingConsumerVarHandleArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpscBlockingConsumerVarHandleArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpscLinkedVarHandleQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscLinkedVarHandleQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpscLinkedVarHandleQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpscUnboundedVarHandleArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscVarHandleArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscVarHandleArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpscVarHandleArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	SpmcVarHandleArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpmcVarHandleArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	SpmcVarHandleArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition e)
int	SpscLinkedVarHandleQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpscLinkedVarHandleQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	SpscLinkedVarHandleQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	SpscUnboundedVarHandleArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpscVarHandleArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpscVarHandleArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	SpscVarHandleArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition e)
private int	MpmcVarHandleArrayQueue.fillOneByOne(MessagePassingQueue.Supplier<E> s, int limit)
(package private) abstract boolean	BaseSpscLinkedVarHandleArrayQueue.offerColdPath(E[] buffer, long mask, long pIndex, long offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) boolean	SpscChunkedVarHandleArrayQueue.offerColdPath(E[] buffer, long mask, long pIndex, long offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) boolean	SpscGrowableVarHandleArrayQueue.offerColdPath(E[] buffer, long mask, long index, long offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) boolean	SpscUnboundedVarHandleArrayQueue.offerColdPath(E[] buffer, long mask, long pIndex, long offset, E v, MessagePassingQueue.Supplier<? extends E> s)
private void	BaseMpscLinkedVarHandleArrayQueue.resize(long oldMask, E[] oldBuffer, long pIndex, E e, MessagePassingQueue.Supplier<E> s)

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

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

Modifier and Type	Method	Description
int	BaseMpscLinkedVarHandleUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	BaseMpscLinkedVarHandleUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	BaseMpscLinkedVarHandleUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	BaseSpscLinkedVarHandleUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	BaseSpscLinkedVarHandleUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	BaseSpscLinkedVarHandleUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpmcVarHandleUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpmcVarHandleUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpmcVarHandleUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpscBlockingConsumerVarHandleUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscBlockingConsumerVarHandleUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpscBlockingConsumerVarHandleUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpscLinkedVarHandleUnpaddedQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscLinkedVarHandleUnpaddedQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpscLinkedVarHandleUnpaddedQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpscUnboundedVarHandleUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscVarHandleUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	MpscVarHandleUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	MpscVarHandleUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	SpmcVarHandleUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpmcVarHandleUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	SpmcVarHandleUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition e)
int	SpscLinkedVarHandleUnpaddedQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpscLinkedVarHandleUnpaddedQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	SpscLinkedVarHandleUnpaddedQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	SpscUnboundedVarHandleUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpscVarHandleUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s)
int	SpscVarHandleUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, int limit)
void	SpscVarHandleUnpaddedArrayQueue.fill(MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition e)
private int	MpmcVarHandleUnpaddedArrayQueue.fillOneByOne(MessagePassingQueue.Supplier<E> s, int limit)
(package private) abstract boolean	BaseSpscLinkedVarHandleUnpaddedArrayQueue.offerColdPath(E[] buffer, long mask, long pIndex, long offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) boolean	SpscChunkedVarHandleUnpaddedArrayQueue.offerColdPath(E[] buffer, long mask, long pIndex, long offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) boolean	SpscGrowableVarHandleUnpaddedArrayQueue.offerColdPath(E[] buffer, long mask, long index, long offset, E v, MessagePassingQueue.Supplier<? extends E> s)
(package private) boolean	SpscUnboundedVarHandleUnpaddedArrayQueue.offerColdPath(E[] buffer, long mask, long pIndex, long offset, E v, MessagePassingQueue.Supplier<? extends E> s)
private void	BaseMpscLinkedVarHandleUnpaddedArrayQueue.resize(long oldMask, E[] oldBuffer, long pIndex, E e, MessagePassingQueue.Supplier<E> s)