PriorityBlockingQueue не блокирует?

Question

У меня есть PriorityBlockingQueue следующим образом:

BlockingQueue<Robble> robbleListQueue = new PriorityBlockingQueue<Robble>(); 

Robble реализует Comparable<Robble> и я могу сортировать списки без проблем, так что я знаю, что мои сравнения работы.

У меня также есть следующие Runnable:

private class RobbleGeneratorRunnable implements Runnable { 
    private final BlockingQueue<Robble> robbleQueue; 
    public RobbleGeneratorRunnable(BlockingQueue<ResultList> robbleQueue) { 
     this.robbleQueue = robbleQueue; 
    } 
    @Override 
    public void run() { 
     try { 
      robbleQueue.put(generateRobble()); 
     } catch (InterruptedException e) { 
      // ... 
     } 
    } 

    private Robble generateRobble() { 
     // ... 
    } 
} 

я нажимаю несколько тысяч этих runnables в ExecutorService, а затем shutdown() и awaitTermination().

В соответствии с BlockingQueue JavaDoc, put(...) является блокирующим действием. Однако, когда я повторяю элементы в очереди, они в основном по порядку - есть некоторые, которые не соответствуют порядку, что указывает на то, что очередь не блокируется должным образом. Как я уже говорил, я могу сортировать Robble, просто отлично.

Что может быть причиной того, что robbleQueue.put(generateRobble()) не заблокировать правильно?

Answer 1

Итерация PriorityQueue или PriorityBlockingQueue явно указывается в Javadoc, который нельзя заказывать. Только add(), peek(), poll() и remove() приказаны. Это не имеет никакого отношения к тому, что блокирование происходит правильно.

Answer 2

PriorityBlockingQueue неограниченная очереди, и если вы читаете Javadocs для пут() говорится:

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

Почему вы ожидаете, что put() заблокировать?

Answer 3

Согласно Javadoc,

итератора при условии, в методе итератора() не гарантируется траверс элементов приоритетной очереди в любом порядке. Если вам нужно заказать обход, рассмотреть вопрос об использовании Arrays.sort (pq.toArray())

Добавить, быстрый взгляд, опрос и удалить должны работать в приоритетной последовательности, но НЕ итератор.