Package org.apache.pekko.util

Class StablePriorityBlockingQueue<E>

java.lang.Object
java.util.AbstractCollection<E>
java.util.AbstractQueue<E>
org.apache.pekko.util.StablePriorityBlockingQueue<E>
All Implemented Interfaces:
Iterable<E>, Collection<E>, Queue<E>, PriorityQueueStabilizer<E>
Direct Known Subclasses:
UnboundedStablePriorityMailbox.MessageQueue
public class StablePriorityBlockingQueue<E> extends AbstractQueue<E> implements PriorityQueueStabilizer<E>
StablePriorityBlockingQueue is a blocking priority queue that preserves order for elements of equal priority. param: capacity - the initial capacity of this Queue, needs to be &gt; 0. param: cmp - Comparator for comparing Queue elements