Класс PriorityBlockingQueue<E>

public class PriorityBlockingQueue<E>
extends AbstractQueue<E>
implements BlockingQueue<E>, Serializable

Неограниченная блокирующая очередь, которая использует те же правила упорядочивания, что и класс PriorityQueue, и предоставляет блокирующие операции извлечения. Хотя эта очередь логически неограничена, попытки добавления могут завершиться неудачей из-за исчерпания ресурсов (вызывая OutOfMemoryError). Этот класс не допускает null элементы. Очередь с приоритетом, использующая естественный порядок, также не допускает вставки несопоставимых объектов (в таком случае возникает ClassCastException).

Этот класс и его итератор реализуют все необязательные методы интерфейсов Collection и Iterator. Итератор, предоставляемый методом iterator(), и итератор Spliterator, предоставляемый методом spliterator(), не гарантируют обхода элементов PriorityBlockingQueue в каком-либо определенном порядке. Если вам нужен упорядоченный обход, рассмотрите использование Arrays.sort(pq.toArray()). Также, метод drainTo может использоваться для удаления некоторых или всех элементов в порядке приоритета и размещения их в другой коллекции.

Операции с этим классом не гарантируют порядок элементов с одинаковым приоритетом. Если вам нужно обеспечить порядок, вы можете определить пользовательские классы или компараторы, использующие вторичный ключ для разрыва связей в значениях приоритета первого уровня. Например, вот класс, который применяет порядок «первым пришёл — первым обслужен» для разрыва связей между сопоставимыми элементами. Для его использования вы бы вставили new FIFOEntry(anEntry) вместо простого объекта записи.

class FIFOEntry<E extends Comparable<? super E>>
     implements Comparable<FIFOEntry<E>> {
   static final AtomicLong seq = new AtomicLong(0);
   final long seqNum;
   final E entry;
   public FIFOEntry(E entry) {
     seqNum = seq.getAndIncrement();
     this.entry = entry;
   }
   public E getEntry() { return entry; }
   public int compareTo(FIFOEntry<E> other) {
     int res = entry.compareTo(other.entry);
     if (res == 0 && other.entry != this.entry)
       res = (seqNum < other.seqNum ? -1 : 1);
     return res;
   }
 }

Этот класс является частью Java Collections Framework.

Подробное описание конструкторов

PriorityBlockingQueue

public PriorityBlockingQueue()

Создаёт PriorityBlockingQueue с начальной ёмкостью по умолчанию (11), упорядочивая элементы в соответствии с их естественным порядком.

PriorityBlockingQueue

public PriorityBlockingQueue(int initialCapacity)

Создаёт PriorityBlockingQueue с указанной начальной ёмкостью, упорядочивая элементы в соответствии с их естественным порядком.

Parameters:

initialCapacity - начальная ёмкость для этой очереди с приоритетом

Throws:

IllegalArgumentException - если initialCapacity меньше 1

PriorityBlockingQueue

public PriorityBlockingQueue(int initialCapacity,
                             Comparator<? super E> comparator)

Создаёт PriorityBlockingQueue с указанной начальной ёмкостью, упорядочивая элементы в соответствии с указанным компаратором.

Parameters:

initialCapacity - начальная ёмкость для этой очереди с приоритетом

comparator - компаратор, который будет использоваться для упорядочивания этой очереди с приоритетом. Если null, будет использован естественный порядок элементов.

Throws:

IllegalArgumentException - если initialCapacity меньше 1

PriorityBlockingQueue

public PriorityBlockingQueue(Collection<? extends E> c)

Создаёт PriorityBlockingQueue, содержащий элементы из указанной коллекции. Если указанная коллекция является SortedSet или PriorityQueue, эта очередь с приоритетом будет упорядочена в соответствии с тем же упорядочиванием. В противном случае эта очередь с приоритетом будет упорядочена в соответствии с естественным порядком элементов.

Parameters:

c - коллекция, элементы которой должны быть помещены в эту очередь с приоритетом

Throws:

ClassCastException - если элементы указанной коллекции не могут быть сравнены друг с другом в соответствии с упорядочиванием очереди с приоритетом

NullPointerException - если указанная коллекция или любой из её элементов равны null