Package org.jctools.queues
Class MessagePassingQueueUtil
- java.lang.Object
-
- org.jctools.queues.MessagePassingQueueUtil
-
public final class MessagePassingQueueUtil extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description MessagePassingQueueUtil()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method 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)
-
-
-
Method Detail
-
drain
public static <E> int drain(MessagePassingQueue<E> queue, MessagePassingQueue.Consumer<E> c, int limit)
-
drain
public static <E> int drain(MessagePassingQueue<E> queue, MessagePassingQueue.Consumer<E> c)
-
drain
public static <E> void drain(MessagePassingQueue<E> queue, MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
-
fill
public static <E> void fill(MessagePassingQueue<E> q, MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
-
fillBounded
public static <E> int fillBounded(MessagePassingQueue<E> q, MessagePassingQueue.Supplier<E> s)
-
fillInBatchesToLimit
public static <E> int fillInBatchesToLimit(MessagePassingQueue<E> q, MessagePassingQueue.Supplier<E> s, int batch, int limit)
-
fillUnbounded
public static <E> int fillUnbounded(MessagePassingQueue<E> q, MessagePassingQueue.Supplier<E> s)
-
-