c#-4.0 - 使用 BlockingCollection 时从消费者任务向生产者任务发送信号

Question

我有一个非常基本的应用程序，它使用生产者任务和消费者任务来处理文件。它基于此处的示例http://msdn.microsoft.com/en-us/library/dd267312.aspx

该程序的基础是 Producer 任务枚举我硬盘上的文件并计算它们的哈希值并执行其他一些操作。一旦 Producer 处理完一个文件，它就会 Enques 文件，然后 Consumer 抓取它。

Consumer 任务必须连接到远程服务器并尝试上传文件。但是，如果消费者遇到错误，例如无法连接到远程服务器，我需要它向生产者任务发出信号，告知它应该停止正在做的事情并终止。如果服务器宕机或宕机，生产者无需继续循环浏览数千个文件。

我已经看到大量通过在 BlockingCollection 对象上使用 .CompleteAdding() 从 Producer 任务向 Consumer 任务发出信号的示例，但我不知道如何从 Consumer 向 Producer 发送信号，表明它应该停止生产。

Answer 1

您可以使用返回队列。如果其中一项产生错误/异常，您可以使用错误数据加载它并将其排队返回给生产者。生产者应该在生成新项目之前从返回队列中 TryTake() 并适当地处理任何返回的项目。这优于使用一些原子布尔值，它使项目能够用扩展的错误信息发回信号，这些信息可用于决定采取什么行动——生产者可能并不总是想要/需要停止。此外，您还可以将错误项目排队到 GUI 列表和/或记录器。

很容易说消费者无论如何都应该退回物品，无论它们是否出错，以便它们可以被重新使用以一直创建新的。但是，除非您使用两个返回队列来确定错误返回的优先级，否则这会在检测/处理错误时引入延迟。

哦 - 另一件事 - 使用上述设计，如果它必须停止，生产者可以将错误的项目保留在本地队列中，偶尔重新发布一个。如果服务器恢复正常（如成功项目的返回所示），生产者可以在生成更多新作业之前再次从本地队列重新发出错误作业。小心，这可以使您的上传系统对服务器重新启动具有弹性。