Uses of Interface
org.jctools.queues.MessagePassingQueue.Supplier
Packages that use MessagePassingQueue.Supplier
Package
Description
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
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.-
Uses of MessagePassingQueue.Supplier in org.jctools.queues
Methods in org.jctools.queues with parameters of type MessagePassingQueue.SupplierModifier and TypeMethodDescriptionint
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.SupplierModifier and TypeMethodDescriptionint
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)