public abstract class AbstractBoundedEventHeap extends AbstractBoundedEventQueue
MessageQueue.DiscardListener
Modifier | Constructor and Description |
---|---|
protected |
AbstractBoundedEventHeap(int capacity,
EventQueueOverflowStrategy overflowStrategy,
java.lang.Object lock,
java.util.Comparator comparator) |
Modifier and Type | Method and Description |
---|---|
protected void |
addElement(Message event) |
protected Message[] |
getAllElements() |
protected Message[] |
getElements(int max) |
protected Message |
getNextElement() |
protected Message |
getNextHeapElement() |
int |
getSize()
access the current size of this queue.
|
boolean |
isEmpty()
check if this queue is empty.
|
protected Message |
removeFirstElement(java.util.Comparator comp) |
java.lang.String |
toString() |
addDiscardListener, getAllMessages, getDiscardPolicyName, getEarliestTimeout, getLeastPriority, getMessage, getMessages, getOldestElement, getOrderPolicyName, getYoungestElement, put, removeDiscardListener
protected AbstractBoundedEventHeap(int capacity, EventQueueOverflowStrategy overflowStrategy, java.lang.Object lock, java.util.Comparator comparator)
protected final Message removeFirstElement(java.util.Comparator comp)
protected final Message[] getAllElements()
getAllElements
in class AbstractBoundedEventQueue
public final boolean isEmpty()
MessageQueue
public final int getSize()
MessageQueue
protected final void addElement(Message event)
addElement
in class AbstractBoundedEventQueue
protected final Message[] getElements(int max)
getElements
in class AbstractBoundedEventQueue
protected final Message getNextHeapElement()
protected final Message getNextElement()
getNextElement
in class AbstractBoundedEventQueue
public final java.lang.String toString()
toString
in class java.lang.Object