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 isConcurrentLinkedQueue
which is an unbounded multi-producer, multi-consumer queue which is further encumbered by the need to implement the full range ofQueue
methods.org.jctools.queues.atomic org.jctools.queues.atomic.unpadded org.jctools.queues.unpadded -
-
Uses of MessagePassingQueue.Supplier in org.jctools.queues
-
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)
-