Packages

c

akka.util

StablePriorityBlockingQueue

class StablePriorityBlockingQueue[E <: AnyRef] extends AbstractQueue[E] with PriorityQueueStabilizer[E]

StablePriorityBlockingQueue is a blocking priority queue that preserves order for elements of equal priority.

Source
StablePriorityQueue.scala
Linear Supertypes
PriorityQueueStabilizer[E], AbstractQueue[E], Queue[E], AbstractCollection[E], Collection[E], Iterable[E], AnyRef, Any
Known Subclasses
MessageQueue
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. StablePriorityBlockingQueue
  2. PriorityQueueStabilizer
  3. AbstractQueue
  4. Queue
  5. AbstractCollection
  6. Collection
  7. Iterable
  8. AnyRef
  9. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new StablePriorityBlockingQueue(capacity: Int, cmp: Comparator[E])

    capacity

    - the initial capacity of this Queue, needs to be > 0.

    cmp

    - Comparator for comparing Queue elements

Value Members

  1. def add(arg0: E): Boolean
    Definition Classes
    AbstractQueue → Queue → AbstractCollection → Collection
  2. def addAll(arg0: Collection[_ <: E]): Boolean
    Definition Classes
    AbstractQueue → AbstractCollection → Collection
  3. val backingQueue: PriorityBlockingQueue[WrappedElement[E]]
    Definition Classes
    StablePriorityBlockingQueue → PriorityQueueStabilizer
  4. def clear(): Unit
    Definition Classes
    AbstractQueue → AbstractCollection → Collection
  5. def contains(arg0: Any): Boolean
    Definition Classes
    AbstractCollection → Collection
  6. def containsAll(arg0: Collection[_]): Boolean
    Definition Classes
    AbstractCollection → Collection
  7. def element(): E
    Definition Classes
    AbstractQueue → Queue
  8. def forEach(arg0: Consumer[_ >: E]): Unit
    Definition Classes
    Iterable
  9. def isEmpty(): Boolean
    Definition Classes
    AbstractCollection → Collection
  10. def iterator(): Iterator[E]
    Definition Classes
    PriorityQueueStabilizer → AbstractCollection → Collection → Iterable
  11. def offer(e: E): Boolean
    Definition Classes
    PriorityQueueStabilizer → Queue
  12. def parallelStream(): Stream[E]
    Definition Classes
    Collection
  13. def peek(): E
    Definition Classes
    PriorityQueueStabilizer → Queue
  14. def poll(): E
    Definition Classes
    PriorityQueueStabilizer → Queue
  15. def remove(): E
    Definition Classes
    AbstractQueue → Queue
  16. def remove(arg0: Any): Boolean
    Definition Classes
    AbstractCollection → Collection
  17. def removeAll(arg0: Collection[_]): Boolean
    Definition Classes
    AbstractCollection → Collection
  18. def removeIf(arg0: Predicate[_ >: E]): Boolean
    Definition Classes
    Collection
  19. def retainAll(arg0: Collection[_]): Boolean
    Definition Classes
    AbstractCollection → Collection
  20. val seqNum: AtomicLong
    Definition Classes
    PriorityQueueStabilizer
  21. def size(): Int
    Definition Classes
    PriorityQueueStabilizer → AbstractCollection → Collection
  22. def spliterator(): Spliterator[E]
    Definition Classes
    Collection → Iterable
  23. def stream(): Stream[E]
    Definition Classes
    Collection
  24. def toArray[T](arg0: Array[T]): Array[T]
    Definition Classes
    AbstractCollection → Collection
  25. def toArray(): Array[AnyRef]
    Definition Classes
    AbstractCollection → Collection
  26. def toString(): String
    Definition Classes
    AbstractCollection → AnyRef → Any