public final class MessagePassingQueueUtil extends Object
Constructor and Description |
---|
MessagePassingQueueUtil() |
Modifier and Type | Method and Description |
---|---|
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)
Copyright © 2008–2021 The Netty Project. All rights reserved.