将第一个元素原子地添加到ConcurrentLinkedQueue

Question

我想以无原子锁的方式使用ConcurrentLinkedQueue：

几个并发线程将事件推送到队列中，其他一些线程将处理它们。队列没有绑定，我不希望任何线程等待或被锁定。然而，阅读部分可能会注意到队列变空了。在无锁实现中，读取线程不能阻塞，只能结束其任务并继续执行其他任务（即作为ExecutorService）。因此，将第一个新事件推送到空队列中的写入程序必须知道它，并且应该重新启动读取器（即，通过向ExecutorService提交新的Runnable）来处理队列。任何进一步提交第二个或第三个事件的线程都不会在意，因为它们可能会认为一些读者已经准备好/提交了。

不幸的是，ConTrentLinkedQueue的add（）方法总是返回true。在添加事件之前或之后询问队列是否为空（）没有帮助，因为它不是原子的。我应该使用一些额外的原子整数来监控队列大小（）还是有更聪明的解决方案？

迪特。

Answer 1

使用原子整数来解决提交争用比锁或同步块更有效。

>

此外，多生产者/单写入者队列的结构也比ConcurrentLinkedQueue更有效。

将其用于actor实现的示例。

另一个例子。

Answer 2

我不太明白你为什么不直接使用ExecutorService。它在内部使用阻塞队列，并负责所有信号本身。

// open ended thread pool
ExecutorService threadPool = Executors.newFixedThreadPool(1);
for (Job job : jobsToDo) {
    threadPool.submit(new MyJobProcessor(job));
}

除非你有充分的理由，否则我不会自己重写同样的逻辑。

如果你想以某种方式利用Hibernate线程，我强烈建议不要费心。线程相对便宜，所以分配一个线程来处理排队的任务是可以的。重复使用线程是不必要的，对我来说似乎是过早的优化。