Java BlockingQueue导致线程不必要的等待。

Question

我使用blocking queue(LinkedBlockingQueue)在几个线程之间同步数据。请看下图。

主线程是一个生产者，它产生对象，然后将它们放入每个消费者的队列中（线程2-10）。需要强调的是，每个消费者都有自己的队列，每个产生的对象都将进入所有消费者的队列。

生产者的运行速度比使用者快得多，因此我们可以假设在使用者运行期间队列不应该为空。当任何使用者的队列达到其容量时，生产者将被阻止（生产者使用 put（）。消费者使用 take（） 从队列中获取对象。

有了这个设置，我会假设当队列为空时，消费者很少（如果可能的话）等待。然而，从我在下面附上的图片中，我可以看到，所有消费者都会不时地排队等待物品；在等待期间，我可以看到制作人正在运行。

这不是我对BlockingQueue的理解，我曾假设，只要生产者生产出某种东西并放入队列，消费者就应该开始工作。我不明白为什么消费者要等这么长时间。

有人可以解释一下吗？有没有简单的方法来分析这种类型的应用程序？

Answer 1

这并不是我对BlockingQueue的理解，我认为只要生产者生产出产品并将其放入队列，消费者就应该开始工作。我无法理解为什么消费者线程上有这么长的等待时间。

这很可能不是阻塞队列的问题。

>

你可能不正确，生产者落后于消费者。也许制作人正在崩溃，有一段时间正在从加载的磁盘中读取数据，结果落后了。

也许消费者正在阻止其他对象而不是 BlockingQueue。消费者如何处理数据？他们是将其写入磁盘还是通过网络发送？他们执行的任何其他操作可以阻止吗？

另一种可能性是，只有几个线程在跟上生产者的进度，所以有很多线程在以后进先出的线程顺序等待。换句话说，如果一个线程刚刚完成，那么它可能会使用制作者添加的最新元素。因此，有几个线程保持忙碌，而其他线程则处于阻塞状态。我不确定您的队列是否就是这样实现的。

有什么简单的html" target="_blank">方法来分析这种应用程序吗？

要做的一件事是查看堆栈跟踪，以查看每个线程被阻塞的位置。如果您的线程实际上正在等待阻塞队列，这将给您一个更好的主意。您可以使用jconsole实时查看线程，或者每隔一段时间发送一个QUIT信号。