哪一个Java阻塞队列对于多个生产者和单个或多个消费者场景是最好的?

问题不在于 Queue 您使用的实现,而不是如何处理限制生产者的问题 如果 你的消费者 不能跟上 . 一种可能的解决方案是创建 LinkedBlockingQueue 有固定的容量,让你的生产商打电话 offer(E e) ,将返回 false 如果队列已满。

另一个可能的解决方案是相应地调整生产者和消费者的数量。

每个生产者都是单独的线程吗?不要忘记,每个线程将为其堆栈分配(默认情况下)512K内存(在您的情况下,只需要为线程分配200MB的VM内存)。你可以通过 -Xss .

或者,你排队的对象有多大?我觉得你没有 队列 问题和某种规模化问题一样多,例如生产商的生产速度快于消费者的消费速度。

似乎LinkedBlockingQueue是解决问题的最佳选择。我建议您使用开关-xx:+heapDumpOnAutofMemoryError运行您的程序,并分析转储文件以查看导致问题的原因。这样你就能更容易地解决问题了。