int |
MpscBlockingConsumerArrayQueue.drain(MessagePassingQueue.Consumer<E> c) |
int |
BaseMpscLinkedArrayQueue.drain(MessagePassingQueue.Consumer<E> c) |
int |
SpscArrayQueue.drain(MessagePassingQueue.Consumer<E> c) |
int |
SpmcArrayQueue.drain(MessagePassingQueue.Consumer<E> c) |
int |
MpUnboundedXaddArrayQueue.drain(MessagePassingQueue.Consumer<E> c) |
int |
MpmcArrayQueue.drain(MessagePassingQueue.Consumer<E> c) |
int |
BaseLinkedQueue.drain(MessagePassingQueue.Consumer<E> c) |
int |
BaseSpscLinkedArrayQueue.drain(MessagePassingQueue.Consumer<E> c) |
int |
MpscUnboundedArrayQueue.drain(MessagePassingQueue.Consumer<E> c) |
int |
MpscArrayQueue.drain(MessagePassingQueue.Consumer<E> c) |
int |
MpscCompoundQueue.drain(MessagePassingQueue.Consumer<E> c) |
int |
MpscBlockingConsumerArrayQueue.drain(MessagePassingQueue.Consumer<E> c,
int limit) |
int |
BaseMpscLinkedArrayQueue.drain(MessagePassingQueue.Consumer<E> c,
int limit) |
int |
SpscArrayQueue.drain(MessagePassingQueue.Consumer<E> c,
int limit) |
int |
SpmcArrayQueue.drain(MessagePassingQueue.Consumer<E> c,
int limit) |
int |
MpscUnboundedXaddArrayQueue.drain(MessagePassingQueue.Consumer<E> c,
int limit) |
int |
MpUnboundedXaddArrayQueue.drain(MessagePassingQueue.Consumer<E> c,
int limit) |
int |
MpmcArrayQueue.drain(MessagePassingQueue.Consumer<E> c,
int limit) |
int |
BaseLinkedQueue.drain(MessagePassingQueue.Consumer<E> c,
int limit) |
int |
BaseSpscLinkedArrayQueue.drain(MessagePassingQueue.Consumer<E> c,
int limit) |
int |
MpscArrayQueue.drain(MessagePassingQueue.Consumer<E> c,
int limit) |
int |
MpscCompoundQueue.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) |
void |
BaseMpscLinkedArrayQueue.drain(MessagePassingQueue.Consumer<E> c,
MessagePassingQueue.WaitStrategy wait,
MessagePassingQueue.ExitCondition exit) |
void |
SpscArrayQueue.drain(MessagePassingQueue.Consumer<E> c,
MessagePassingQueue.WaitStrategy w,
MessagePassingQueue.ExitCondition exit) |
void |
SpmcArrayQueue.drain(MessagePassingQueue.Consumer<E> c,
MessagePassingQueue.WaitStrategy w,
MessagePassingQueue.ExitCondition exit) |
void |
MpUnboundedXaddArrayQueue.drain(MessagePassingQueue.Consumer<E> c,
MessagePassingQueue.WaitStrategy wait,
MessagePassingQueue.ExitCondition exit) |
void |
MpmcArrayQueue.drain(MessagePassingQueue.Consumer<E> c,
MessagePassingQueue.WaitStrategy w,
MessagePassingQueue.ExitCondition exit) |
void |
BaseLinkedQueue.drain(MessagePassingQueue.Consumer<E> c,
MessagePassingQueue.WaitStrategy wait,
MessagePassingQueue.ExitCondition exit) |
void |
BaseSpscLinkedArrayQueue.drain(MessagePassingQueue.Consumer<E> c,
MessagePassingQueue.WaitStrategy wait,
MessagePassingQueue.ExitCondition exit) |
void |
MpscArrayQueue.drain(MessagePassingQueue.Consumer<E> c,
MessagePassingQueue.WaitStrategy w,
MessagePassingQueue.ExitCondition exit) |
void |
MpscCompoundQueue.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) |
private int |
MpmcArrayQueue.drainOneByOne(MessagePassingQueue.Consumer<E> c,
int limit) |