StablePriorityBlockingQueue

java.lang.Object
- java.util.AbstractCollection<E>
- - java.util.AbstractQueue<E>
  - - org.apache.pekko.util.StablePriorityBlockingQueue<E>

All Implemented Interfaces:

java.lang.Iterable<E>, java.util.Collection<E>, java.util.Queue<E>, PriorityQueueStabilizer<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 > 0. param: cmp - Comparator for comparing Queue elements

Nested Class Summary
- Nested classes/interfaces inherited from interface org.apache.pekko.util.PriorityQueueStabilizer
  PriorityQueueStabilizer.WrappedElement<E>, PriorityQueueStabilizer.WrappedElementComparator<E>

Constructor Summary

Constructors
Constructor Description

StablePriorityBlockingQueue(int capacity, java.util.Comparator<E> cmp)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`java.util.concurrent.PriorityBlockingQueue<PriorityQueueStabilizer.WrappedElement<E>>`	`backingQueue()`
`protected void`	`org$apache$pekko$util$PriorityQueueStabilizer$_setter_$seqNum_$eq(java.util.concurrent.atomic.AtomicLong x$1)`
`java.util.concurrent.atomic.AtomicLong`	`seqNum()`

Methods inherited from class java.util.AbstractQueue
add, addAll, clear, element, remove

Methods inherited from class java.util.AbstractCollection
contains, containsAll, isEmpty, iterator, remove, removeAll, retainAll, size, toArray, toArray, toString

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Collection
contains, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, remove, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray, toArray

Methods inherited from interface java.lang.Iterable
forEach

Methods inherited from interface org.apache.pekko.util.PriorityQueueStabilizer
iterator, offer, peek, poll, size

Methods inherited from interface java.util.Queue
offer, peek, poll

Constructor Detail

StablePriorityBlockingQueue

public StablePriorityBlockingQueue(int capacity,
                                   java.util.Comparator<E> cmp)

Method Detail
- backingQueue
```
public java.util.concurrent.PriorityBlockingQueue<PriorityQueueStabilizer.WrappedElement<E>> backingQueue()
```
  Specified by:
  
  backingQueue in interface PriorityQueueStabilizer<E>
- org$apache$pekko$util$PriorityQueueStabilizer$_setter_$seqNum_$eq
```
protected void org$apache$pekko$util$PriorityQueueStabilizer$_setter_$seqNum_$eq(java.util.concurrent.atomic.AtomicLong x$1)
```
  Specified by:
  
  org$apache$pekko$util$PriorityQueueStabilizer$_setter_$seqNum_$eq in interface PriorityQueueStabilizer<E>
- seqNum
```
public java.util.concurrent.atomic.AtomicLong seqNum()
```
  Specified by:
  
  seqNum in interface PriorityQueueStabilizer<E>