java - 可交换工作队列

Question

这个有一个名字，但我不知道它是什么所以很难用谷歌搜索。

我正在寻找的是 java 并发实用程序中的一些东西，它是一对队列，一个由生产者使用的“待定”队列，以及一个由消费者使用的“处理”队列，消费者可以在其中交换原子队列。如果以这种方式使用(1 个生产者线程，1 个消费者线程)，各个队列不需要是线程安全的，只需对它们的引用即可。

我知道我以前在某个地方见过这个，我可能可以自己拼凑出这样的东西，但如果它已经存在，我宁愿使用它。

编辑:我想我正在寻找的原语是一对可以原子交换的原子引用。 (我可以自己添加队列。)

---

edit 2: @Alex Miller 回答了我一直在想但想不起来的烦人问题。然而，这并不能解决我的问题，因为它是一个线程障碍，我希望生产者不必阻塞。

@sfossin 关于交换对队列的引用的观点很好；我想要的是，当消费者开始从队列中检索和处理项目时，所有这些队列项目都必须是完整的，生产者之后不能添加任何项目；生产者现在必须将项目添加到另一个队列。因此，配对/交换的原子引用集将不起作用。

(这有点像如果有 2 辆校车，其中一辆总是在等乘客，另一辆总是把他们送到别处。一旦司机开走，就是这样，你必须上另一辆公共(public)汽车。拥有引用允许生产者访问总线，即使它已经离开，这是不允许的。)

我想我会做的是使用单个 ConcurrentLinkedQueue并具有消费者添加到队列中的哨兵值。这允许有多个生产者，而不仅仅是 1 个。为了让消费者处理队列中的成批项目，消费者等待队列中至少有 1 个项目，然后在队列的末尾插入哨兵排队，并删除项目，直到哨兵被删除。然后消费者在批处理之间做任何它必须做的事情。这就是我想要的行为。

它不一定需要保证非阻塞方法(锁定或 synchronized 方法是选项)，但如果有一种简单的方法来构建它，那么它是首选我的申请。

Answer 1

Exchanger ？