public final class MessagePassingQueueUtil
extends java.lang.Object
Modifier | Constructor and Description |
---|---|
private |
MessagePassingQueueUtil() |
Modifier and Type | Method and Description |
---|---|
static <E> int |
drain(MessagePassingQueue<? extends E> queue,
MessagePassingQueue.Consumer<? super E> c) |
static <E> int |
drain(MessagePassingQueue<? extends E> queue,
MessagePassingQueue.Consumer<? super E> c,
int limit) |
static <E> void |
drain(MessagePassingQueue<? extends E> queue,
MessagePassingQueue.Consumer<? super E> c,
MessagePassingQueue.WaitStrategy wait,
MessagePassingQueue.ExitCondition exit) |
public static <E> int drain(MessagePassingQueue<? extends E> queue, MessagePassingQueue.Consumer<? super E> c, int limit)
public static <E> int drain(MessagePassingQueue<? extends E> queue, MessagePassingQueue.Consumer<? super E> c)
public static <E> void drain(MessagePassingQueue<? extends E> queue, MessagePassingQueue.Consumer<? super E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)