Package io.netty.util
Class Recycler.BlockingMessageQueue<T>
java.lang.Object
io.netty.util.Recycler.BlockingMessageQueue<T>
- All Implemented Interfaces:
org.jctools.queues.MessagePassingQueue<T>
private static final class Recycler.BlockingMessageQueue<T>
extends Object
implements org.jctools.queues.MessagePassingQueue<T>
This is an implementation of
MessagePassingQueue
, similar to what might be returned from
PlatformDependent.newMpscQueue(int)
, but intended to be used for debugging purpose.
The implementation relies on synchronised monitor locks for thread-safety.
The fill
bulk operation is not supported by this implementation.-
Nested Class Summary
Nested classes/interfaces inherited from interface org.jctools.queues.MessagePassingQueue
org.jctools.queues.MessagePassingQueue.Consumer<T>, org.jctools.queues.MessagePassingQueue.ExitCondition, org.jctools.queues.MessagePassingQueue.Supplier<T>, org.jctools.queues.MessagePassingQueue.WaitStrategy
-
Field Summary
FieldsFields inherited from interface org.jctools.queues.MessagePassingQueue
UNBOUNDED_CAPACITY
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionint
capacity()
void
clear()
int
int
void
drain
(org.jctools.queues.MessagePassingQueue.Consumer<T> c, org.jctools.queues.MessagePassingQueue.WaitStrategy wait, org.jctools.queues.MessagePassingQueue.ExitCondition exit) int
int
void
fill
(org.jctools.queues.MessagePassingQueue.Supplier<T> s, org.jctools.queues.MessagePassingQueue.WaitStrategy wait, org.jctools.queues.MessagePassingQueue.ExitCondition exit) boolean
isEmpty()
boolean
peek()
poll()
boolean
relaxedOffer
(T e) int
size()
-
Field Details
-
deque
-
maxCapacity
private final int maxCapacity
-
-
Constructor Details
-
BlockingMessageQueue
BlockingMessageQueue(int maxCapacity)
-
-
Method Details
-
offer
- Specified by:
offer
in interfaceorg.jctools.queues.MessagePassingQueue<T>
-
poll
- Specified by:
poll
in interfaceorg.jctools.queues.MessagePassingQueue<T>
-
peek
- Specified by:
peek
in interfaceorg.jctools.queues.MessagePassingQueue<T>
-
size
public int size()- Specified by:
size
in interfaceorg.jctools.queues.MessagePassingQueue<T>
-
clear
public void clear()- Specified by:
clear
in interfaceorg.jctools.queues.MessagePassingQueue<T>
-
isEmpty
public boolean isEmpty()- Specified by:
isEmpty
in interfaceorg.jctools.queues.MessagePassingQueue<T>
-
capacity
public int capacity()- Specified by:
capacity
in interfaceorg.jctools.queues.MessagePassingQueue<T>
-
relaxedOffer
- Specified by:
relaxedOffer
in interfaceorg.jctools.queues.MessagePassingQueue<T>
-
relaxedPoll
- Specified by:
relaxedPoll
in interfaceorg.jctools.queues.MessagePassingQueue<T>
-
relaxedPeek
- Specified by:
relaxedPeek
in interfaceorg.jctools.queues.MessagePassingQueue<T>
-
drain
- Specified by:
drain
in interfaceorg.jctools.queues.MessagePassingQueue<T>
-
fill
- Specified by:
fill
in interfaceorg.jctools.queues.MessagePassingQueue<T>
-
drain
- Specified by:
drain
in interfaceorg.jctools.queues.MessagePassingQueue<T>
-
fill
- Specified by:
fill
in interfaceorg.jctools.queues.MessagePassingQueue<T>
-
drain
public void drain(org.jctools.queues.MessagePassingQueue.Consumer<T> c, org.jctools.queues.MessagePassingQueue.WaitStrategy wait, org.jctools.queues.MessagePassingQueue.ExitCondition exit) - Specified by:
drain
in interfaceorg.jctools.queues.MessagePassingQueue<T>
-
fill
public void fill(org.jctools.queues.MessagePassingQueue.Supplier<T> s, org.jctools.queues.MessagePassingQueue.WaitStrategy wait, org.jctools.queues.MessagePassingQueue.ExitCondition exit) - Specified by:
fill
in interfaceorg.jctools.queues.MessagePassingQueue<T>
-