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