这两种实现有什么区别？在哪些情况下应该使用其中一种而不是另一种？

我正在尝试从管道中读取行并进行处理，但我做了一些傻事，无法弄清楚具体是什么。生成器将会不断地产生行，就像这样： producer.pyimport time while True: print 'Data' time.sleep(1) 消费者只需要定期检查行即可： cons...

我需要开发一个多线程应用程序，其中将有多个线程，每个线程都会生成自定义事件日志，需要将其保存在队列中（不是Microsoft MSMQ）。 还将有另一个线程从队列中读取日志数据并操作它，将某些信息保存到文件中。基本上，我们正在实现多生产者、单消费者的范例。 请问有人能提供如何在C++或C#...

我尝试使用 Apache Kafka 执行一个样例生产者-消费者应用程序。我从https://www.apache.org/dyn/closer.cgi?path=/kafka/0.10.0.0/kafka-0.10.0.0-src.tgz下载了它。然后我开始按照http://www.java...

我在多线程编程方面还很新，只知道最常见的生产者-消费者-队列。 我正在使用boost c++库，不知道是更好地使用boost::lockfree::queue还是使用包装器类std::queue，后者使用了`mutex`和`condition_variable`。 什么情况下更适合使用无...

我在C# in a Nutshell书籍的示例生产者消费者队列中复用了BlockingCollection(http://www.albahari.com/threading/part5.aspx#_BlockingCollectionT)，但有同事问道： “为什么在集合的Dispose中不调...

我已经几年学习Python和数据库了。 但是我想要提高我有限的JavaScript知识。在我的玩具项目中，我想在Web浏览器中使用异步队列，并使用AngularJS。 在Python中有一个很好的类叫做multiprocessing.Queue，我以前用过它。 现在我正在寻找像这样的东西，但是...

我如何使用 事件和委托 在 C# 中实现 生产者/消费者 模式？在使用这些设计模式时，我需要注意什么资源问题？是否有任何需要注意的边缘情况？

我有一个BlockingCollection，生产者任务向其中添加项目，消费者任务移除项目。 现在我想限制集合中的项目数量，如果添加更多项目，则自动“丢弃”旧数据。该集合在同一时间内永远不应超过最近添加的N个项目。 因此，如果生产者比消费者更快地添加新项目，我希望消费者仅处理最新的项目。 ...

嗨，我正在研究使用快速可靠的生产者消费者队列进行线程移交。我的工作环境是Windows和VC++。 我根据Anthony Williams的队列设计，基本上是一个带有boost::condition_variable的boost::mutex。现在，通常notify_one()和唤醒之间的时...