Package akka.util

Class StablePriorityBlockingQueue<E>

  • All Implemented Interfaces:
    PriorityQueueStabilizer<E>, java.lang.Iterable<E>, java.util.Collection<E>, java.util.Queue<E>
    Direct Known Subclasses:
    UnboundedStablePriorityMailbox.MessageQueue

    public class StablePriorityBlockingQueue<E>
    extends java.util.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