0

我一直在玩阻塞队列和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呢？

4

1 回答 1

2

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

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

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

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

于 2021-03-12T19:06:00.107 回答