生产者消费者使用公共 BlockingCollection 分离的类

Question

希望有人可以就生产者/消费者模式提供一些建议——特别是关于如何最好地实现对所有生产者/消费者类实例通用的队列/BlockingCollection？

让我们简化场景；考虑一下我有；

• 单个生产者类
• 单个消费者类。
• 一项服务 包含生产者和消费者实例的类 班级。服务类只是告诉生产者/消费者开始 并停止工作。

生产者将填充 BlockingCollection

消费者需要从同一个 BlockingCollection 中读取数据

正如本文所演示的，这一切都很容易做到；

https://msdn.microsoft.com/en-us/library/dd287186.aspx?cs-save-lang=1&cs-lang=csharp#code-snippet-2

这个例子本质上是同一个类中的生产者和消费者，引用一个公共队列/阻塞集合当然是微不足道的，因为对对象的引用是同一个类中的一个私有成员。

如果我将生产者和消费者分成不同的类，那么这就提出了如何拥有一个通用的 BlockingCollection 的问题。

我是否应该将“服务类”设为静态/共享类，在此类中创建 BlockingCollection 并将其公开为朋友/公共成员？

common Queue应该放在哪里？

提前致谢！

Answer 1

只需设计您的 Producer 和 Consumer 类以接受 BlockingCollection 作为构造函数参数。

然后，无论您在何处实例化这些类，甚至每个实例不止一个，只要确保将BlockingCollection 的同一个实例传递给所有生产者和消费者。完成此操作后，无需保留对BlockingCollection 的其他外部引用，除非您需要它用于其他用途。每个Producer 和Consumer 都拥有对同一个BlockingCollection 实例的私有引用就足够了。

基本上，它看起来像这样：

public class Producer {
    private BlockingCollection queue;

    public Producer(BlockingCollection queue) {
        this.queue = queue;
    }

    // more code...
}

public class Consumer {
    private BlockingCollection queue;

    public Consumer(BlockingCollection queue) {
        this.queue = queue;
    }

    // more code...
}

// The exact design of this class is up to you. This is just an example.
public class ProducerConsumerBuilder {
    public void BuildProducerAndConsumer(out Producer producer, out Consumer consumer) {
        BlockingCollection queue = new BlockingCollection();
        producer = new Producer(queue);
        consumer = new Consumer(queue);

        // No need to save a reference to "queue" here any longer,
        // unless you need it for something else.
        // It's enough that the producer and consumer each
        // hold their own private reference to the same queue.
    }
}