akka.util

Interface PriorityQueueStabilizer<E>

All Known Implementing Classes:

StablePriorityBlockingQueue, StablePriorityQueue, UnboundedStablePriorityMailbox.MessageQueue

public interface PriorityQueueStabilizer<E>

PriorityQueueStabilizer wraps a priority queue so that it respects FIFO for elements of equal priority.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	PriorityQueueStabilizer.WrappedElement<E>
static class	PriorityQueueStabilizer.WrappedElementComparator<E>

Method Summary

Modifier and Type	Method and Description
java.util.AbstractQueue<PriorityQueueStabilizer.WrappedElement<E>>	backingQueue()
java.util.Iterator<E>	iterator()
boolean	offer(E e)
E	peek()
E	poll()
java.util.concurrent.atomic.AtomicLong	seqNum()
int	size()

Method Detail

backingQueue

java.util.AbstractQueue<PriorityQueueStabilizer.WrappedElement<E>> backingQueue()

seqNum

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

peek

E peek()

size

int size()

offer

boolean offer(E e)

iterator

java.util.Iterator<E> iterator()

poll

E poll()