PriorityBlockingQueue 的目的是什么？

问题描述

我一直在 playing 处理阻塞队列和 PriorityQueue，这让我开始思考。我看不到 PriorityBlockingQueue 的良好用例。优先级队列的重点是在检索之前对放入其中的值进行排序。阻塞队列意味着值被同时插入并从中检索。但是，如果是这样，您将永远无法保证排序顺序。

BlockingQueue<Integer> q = new PriorityBlockingQueue<>();

new Thread (()->{ randomSleep(); q.put(2); randomSleep(); q.put(0); }).start();
new Thread (()->{ randomSleep(); q.put(3); randomSleep(); q.put(1); }).start();

ArrayList<Integer> ordered = new ArrayList<>(4);
for (int i = 0; i < 4; i++) {
    randomSleep();
    ordered.add(q.take());
}
System.out.println(ordered);

在这个例子中，主线程获取提供值的顺序是非常随机的，这似乎违背了优先队列的目的。即使只有一个生产者和一个消费者，也无法保证顺序。

那么，PriorityBlockingQueue 有什么用？

解决方法

在这个例子中，主线程获取提供的顺序 值相当随机

好吧，您在插入和检索这些元素期间存在竞争条件。因此，它看起来是随机的。

尽管如此，您可以使用例如 PriorityBlockingQueue 来按顺序排列一些元素（或任务），这些元素（或任务）需要由多个线程并行拾取它们的最高优先级元素/任务强>。在这种情况下，您可以利用结构的线程安全属性来保证优先级最高的元素始终排在最前面。

一个例子是一个任务队列，其中这些任务具有优先级，并且您希望并行处理这些相同的任务。