public static class UnboundedPriorityMailbox.MessageQueue extends java.util.concurrent.PriorityBlockingQueue<Envelope> implements UnboundedQueueBasedMessageQueue
Constructor and Description |
---|
MessageQueue(int initialCapacity,
java.util.Comparator<Envelope> cmp) |
Modifier and Type | Method and Description |
---|---|
java.util.Queue<Envelope> |
queue() |
add, clear, comparator, contains, drainTo, drainTo, iterator, offer, offer, peek, poll, poll, put, remainingCapacity, remove, size, spliterator, take, toArray, toArray, toString
containsAll, isEmpty, removeAll, retainAll
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
dequeue, enqueue
cleanUp, hasMessages, numberOfMessages
public MessageQueue(int initialCapacity, java.util.Comparator<Envelope> cmp)
public final java.util.Queue<Envelope> queue()
queue
in interface QueueBasedMessageQueue