阻塞队列与生产者消费者模式的经典实现答案

【问题标题】：Blocking Queue Vs Classical implementation of Producer Consumer pattern阻塞队列与生产者消费者模式的经典实现
【发布时间】：2013-11-27 20:38:27
【问题描述】：

我知道在实现生产者消费者模式时，我们可以使用BlockingQueue 而不是经典的wait() 和notify()。我的问题是，哪种实现更有效？在一篇关于阻塞队列的文章中写道——“你不需要使用wait 和notify 在生产者和消费者之间进行通信”

【问题讨论】：

我会更担心可读性和维护。通过使用简单的数据结构，您将为未来的开发人员节省多少时间？另一方面，如果你推出自己的解决方案，他们会浪费多少时间来弄清楚你为什么不只使用 BlockingQueue？
没想到：P

【解决方案1】：

BlockingQueue 会更快，因为它不使用等待/通知或同步进行队列访问。所有并发包都使用原子类实现无锁算法。

考虑一个由 100 个元素组成的队列，以及 1000 个想要完成工作的线程。使用同步实现，对于每个元素 999 个线程需要等待，直到 1 个线程选择了它的任务。使用无锁算法，100 个线程同时选择他们的任务，只有其他 900 个需要等待。

【讨论】：

【解决方案2】：

如果每秒产生/消耗的对象数量少于 100000，那么您将无法看到标准实现或您自己的实现的差异。

否则，您可以使用以下选项来加快代码速度：

使用 ArrayBlockingQueue 代替 LinkedBlockingQueue：无需为每个传输的消息创建包装对象。 ArrayBlockingQueue 的另一个优点是，如果队列已满，生产者线程会被阻塞 - 事实上，如果消费者不快，生产者应该放慢速度，否则我们最终会耗尽内存。
分批发送消息，例如以每组 10 条消息的形式发送。这减少了共享对象上的线程争用。

如果您必须每秒发送数千万条消息，请查看Lmax Disruptor。

【讨论】：

【解决方案3】：

BlockingQueue 只是一个将 wait() 和 notify() 用于这种常见用途的类。一般来说，自己做只是重新发明轮子，只有当你有很多生产者和消费者并且你可以以某种特定于你的代码的方式进行优化时才值得。

【讨论】：