public final class MessagePassingQueueUtil
extends java.lang.Object
限定符和类型 | 方法和说明 |
---|---|
static <E> int |
drain(MessagePassingQueue<E> queue,
MessagePassingQueue.Consumer<E> c) |
static <E> int |
drain(MessagePassingQueue<E> queue,
MessagePassingQueue.Consumer<E> c,
int limit) |
static <E> void |
drain(MessagePassingQueue<E> queue,
MessagePassingQueue.Consumer<E> c,
MessagePassingQueue.WaitStrategy wait,
MessagePassingQueue.ExitCondition exit) |
static <E> void |
fill(MessagePassingQueue<E> q,
MessagePassingQueue.Supplier<E> s,
MessagePassingQueue.WaitStrategy wait,
MessagePassingQueue.ExitCondition exit) |
static <E> int |
fillBounded(MessagePassingQueue<E> q,
MessagePassingQueue.Supplier<E> s) |
static <E> int |
fillInBatchesToLimit(MessagePassingQueue<E> q,
MessagePassingQueue.Supplier<E> s,
int batch,
int limit) |
static <E> int |
fillUnbounded(MessagePassingQueue<E> q,
MessagePassingQueue.Supplier<E> s) |
public static <E> int drain(MessagePassingQueue<E> queue, MessagePassingQueue.Consumer<E> c, int limit)
public static <E> int drain(MessagePassingQueue<E> queue, MessagePassingQueue.Consumer<E> c)
public static <E> void drain(MessagePassingQueue<E> queue, MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
public static <E> void fill(MessagePassingQueue<E> q, MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
public static <E> int fillBounded(MessagePassingQueue<E> q, MessagePassingQueue.Supplier<E> s)
public static <E> int fillInBatchesToLimit(MessagePassingQueue<E> q, MessagePassingQueue.Supplier<E> s, int batch, int limit)
public static <E> int fillUnbounded(MessagePassingQueue<E> q, MessagePassingQueue.Supplier<E> s)