Uses of Interface
org.jctools.queues.MessagePassingQueue.Consumer

Packages that use MessagePassingQueue.Consumer

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.Consumer in org.jctools.queues

Methods in org.jctools.queues with parameters of type MessagePassingQueue.Consumer

Modifier and Type	Method	Description
int	BaseLinkedQueue.drain(MessagePassingQueue.Consumer<E> c)
int	BaseLinkedQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	BaseLinkedQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	BaseMpscLinkedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	BaseMpscLinkedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	BaseMpscLinkedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	BaseSpscLinkedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	BaseSpscLinkedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	BaseSpscLinkedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	FFBuffer.drain(MessagePassingQueue.Consumer<E> c)
int	FFBuffer.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	FFBuffer.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MessagePassingQueue.drain(MessagePassingQueue.Consumer<T> c)	Remove all available item from the queue and hand to consume.
int	MessagePassingQueue.drain(MessagePassingQueue.Consumer<T> c, int limit)	Remove up to limit elements from the queue and hand to consume.
void	MessagePassingQueue.drain(MessagePassingQueue.Consumer<T> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)	Remove elements from the queue and hand to consume forever.
static <E> int	MessagePassingQueueUtil.drain(MessagePassingQueue<E> queue, MessagePassingQueue.Consumer<E> c)
static <E> int	MessagePassingQueueUtil.drain(MessagePassingQueue<E> queue, MessagePassingQueue.Consumer<E> c, int limit)
static <E> void	MessagePassingQueueUtil.drain(MessagePassingQueue<E> queue, MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpmcArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	MpmcArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	MpmcArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	MpscArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	MpscArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	MpscArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	MpscBlockingConsumerArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	MpscBlockingConsumerArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
int	MpscBlockingConsumerArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit, long timeout, java.util.concurrent.TimeUnit unit)	Remove up to limit elements from the queue and hand to consume, waiting up to the specified wait time if necessary for an element to become available.
void	MpscBlockingConsumerArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	MpscCompoundQueue.drain(MessagePassingQueue.Consumer<E> c)
int	MpscCompoundQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	MpscCompoundQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpscRelaxedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	MpscRelaxedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	MpscRelaxedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	MpscSequencedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	MpscSequencedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	MpscSequencedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpscUnboundedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	MpscUnboundedXaddArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
int	MpUnboundedXaddArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	MpUnboundedXaddArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	MpUnboundedXaddArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	SpmcArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	SpmcArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	SpmcArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	SpscArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	SpscArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	SpscArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
private int	MpmcArrayQueue.drainOneByOne(MessagePassingQueue.Consumer<E> c, int limit)

Uses of MessagePassingQueue.Consumer in org.jctools.queues.atomic

Methods in org.jctools.queues.atomic with parameters of type MessagePassingQueue.Consumer

Modifier and Type	Method	Description
int	BaseLinkedAtomicQueue.drain(MessagePassingQueue.Consumer<E> c)
int	BaseLinkedAtomicQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	BaseLinkedAtomicQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	BaseMpscLinkedAtomicArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	BaseMpscLinkedAtomicArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	BaseMpscLinkedAtomicArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	BaseSpscLinkedAtomicArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	BaseSpscLinkedAtomicArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	BaseSpscLinkedAtomicArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpmcAtomicArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	MpmcAtomicArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	MpmcAtomicArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	MpscAtomicArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	MpscAtomicArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	MpscAtomicArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	MpscRelaxedAtomicArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	MpscRelaxedAtomicArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	MpscRelaxedAtomicArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	MpscUnboundedAtomicArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	SpmcAtomicArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	SpmcAtomicArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	SpmcAtomicArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	SpscAtomicArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	SpscAtomicArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	SpscAtomicArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
private int	MpmcAtomicArrayQueue.drainOneByOne(MessagePassingQueue.Consumer<E> c, int limit)

Uses of MessagePassingQueue.Consumer in org.jctools.queues.atomic.unpadded

Methods in org.jctools.queues.atomic.unpadded with parameters of type MessagePassingQueue.Consumer

Modifier and Type	Method	Description
int	BaseLinkedAtomicUnpaddedQueue.drain(MessagePassingQueue.Consumer<E> c)
int	BaseLinkedAtomicUnpaddedQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	BaseLinkedAtomicUnpaddedQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	BaseMpscLinkedAtomicUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	BaseMpscLinkedAtomicUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	BaseMpscLinkedAtomicUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	BaseSpscLinkedAtomicUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	BaseSpscLinkedAtomicUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	BaseSpscLinkedAtomicUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpmcAtomicUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	MpmcAtomicUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	MpmcAtomicUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	MpscAtomicUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	MpscAtomicUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	MpscAtomicUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	MpscUnboundedAtomicUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	SpmcAtomicUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	SpmcAtomicUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	SpmcAtomicUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	SpscAtomicUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	SpscAtomicUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	SpscAtomicUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
private int	MpmcAtomicUnpaddedArrayQueue.drainOneByOne(MessagePassingQueue.Consumer<E> c, int limit)

Uses of MessagePassingQueue.Consumer in org.jctools.queues.unpadded

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

Modifier and Type	Method	Description
int	BaseLinkedUnpaddedQueue.drain(MessagePassingQueue.Consumer<E> c)
int	BaseLinkedUnpaddedQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	BaseLinkedUnpaddedQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	BaseMpscLinkedUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	BaseMpscLinkedUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	BaseMpscLinkedUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	BaseSpscLinkedUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	BaseSpscLinkedUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	BaseSpscLinkedUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpmcUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	MpmcUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	MpmcUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	MpscUnboundedUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	MpscUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	MpscUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	MpscUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	SpmcUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	SpmcUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	SpmcUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	SpscUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	SpscUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	SpscUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
private int	MpmcUnpaddedArrayQueue.drainOneByOne(MessagePassingQueue.Consumer<E> c, int limit)

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

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

Modifier and Type	Method	Description
int	BaseLinkedVarHandleQueue.drain(MessagePassingQueue.Consumer<E> c)
int	BaseLinkedVarHandleQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	BaseLinkedVarHandleQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	BaseMpscLinkedVarHandleArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	BaseMpscLinkedVarHandleArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	BaseMpscLinkedVarHandleArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	BaseSpscLinkedVarHandleArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	BaseSpscLinkedVarHandleArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	BaseSpscLinkedVarHandleArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpmcVarHandleArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	MpmcVarHandleArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	MpmcVarHandleArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	MpscBlockingConsumerVarHandleArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	MpscBlockingConsumerVarHandleArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
int	MpscBlockingConsumerVarHandleArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit, long timeout, java.util.concurrent.TimeUnit unit)	Remove up to limit elements from the queue and hand to consume, waiting up to the specified wait time if necessary for an element to become available.
void	MpscBlockingConsumerVarHandleArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	MpscUnboundedVarHandleArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	MpscVarHandleArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	MpscVarHandleArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	MpscVarHandleArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	SpmcVarHandleArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	SpmcVarHandleArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	SpmcVarHandleArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	SpscVarHandleArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	SpscVarHandleArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	SpscVarHandleArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
private int	MpmcVarHandleArrayQueue.drainOneByOne(MessagePassingQueue.Consumer<E> c, int limit)

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

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

Modifier and Type	Method	Description
int	BaseLinkedVarHandleUnpaddedQueue.drain(MessagePassingQueue.Consumer<E> c)
int	BaseLinkedVarHandleUnpaddedQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	BaseLinkedVarHandleUnpaddedQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	BaseMpscLinkedVarHandleUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	BaseMpscLinkedVarHandleUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	BaseMpscLinkedVarHandleUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	BaseSpscLinkedVarHandleUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	BaseSpscLinkedVarHandleUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	BaseSpscLinkedVarHandleUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
int	MpmcVarHandleUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	MpmcVarHandleUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	MpmcVarHandleUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	MpscBlockingConsumerVarHandleUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	MpscBlockingConsumerVarHandleUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
int	MpscBlockingConsumerVarHandleUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit, long timeout, java.util.concurrent.TimeUnit unit)	Remove up to limit elements from the queue and hand to consume, waiting up to the specified wait time if necessary for an element to become available.
void	MpscBlockingConsumerVarHandleUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	MpscUnboundedVarHandleUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	MpscVarHandleUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	MpscVarHandleUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	MpscVarHandleUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	SpmcVarHandleUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	SpmcVarHandleUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	SpmcVarHandleUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
int	SpscVarHandleUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c)
int	SpscVarHandleUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, int limit)
void	SpscVarHandleUnpaddedArrayQueue.drain(MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy w, MessagePassingQueue.ExitCondition exit)
private int	MpmcVarHandleUnpaddedArrayQueue.drainOneByOne(MessagePassingQueue.Consumer<E> c, int limit)