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 -
-
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)
-