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