Package akka.util

Class StablePriorityBlockingQueue<E>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

akka.util.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

Nested Class Summary

Nested classes/interfaces inherited from interface akka.util.PriorityQueueStabilizer

PriorityQueueStabilizer.WrappedElement<E>, PriorityQueueStabilizer.WrappedElementComparator<E>

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected void	akka$util$PriorityQueueStabilizer$_setter_$seqNum_$eq(java.util.concurrent.atomic.AtomicLong x$1)
java.util.concurrent.PriorityBlockingQueue<PriorityQueueStabilizer.WrappedElement<E>>	backingQueue()
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 akka.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

akka$util$PriorityQueueStabilizer$_setter_$seqNum_$eq

protected void akka$util$PriorityQueueStabilizer$_setter_$seqNum_$eq(java.util.concurrent.atomic.AtomicLong x$1)

Specified by:

akka$util$PriorityQueueStabilizer$_setter_$seqNum_$eq in interface PriorityQueueStabilizer<E>

backingQueue

public java.util.concurrent.PriorityBlockingQueue<PriorityQueueStabilizer.WrappedElement<E>> backingQueue()

Specified by:

backingQueue in interface PriorityQueueStabilizer<E>

seqNum

public java.util.concurrent.atomic.AtomicLong seqNum()

Specified by:

seqNum in interface PriorityQueueStabilizer<E>