c# - 我可以并行添加到 ConcurrentQueue 并从 ConcurrentQueue 中产生吗？

Question

我有一个类可以从 Web 服务获取对象。我对这些对象的使用与顺序无关，因此我并行发出 Web 请求并将结果添加到 ConcurrentQueue 中。

同时，在发出请求时，我们可以处理响应。

因此，我希望能够在将我的项目添加到 ConcurrentQueue 时对其内容进行迭代。

如何让一个类(class)填满队列，而另一个类(class)清空队列。几乎可以肯定，它的清空速度会比填充速度快，因此我不能在没有 yield 的情况下只枚举它，因为集合将是空的并且不会等待。

Answer 1

使用 BlockingCollection 包装 ConcurrentQueue(BlockingCollection 的默认后备存储是 ConcurrentQueue，所以你甚至不需要明确说明这一点。

这允许您将消费者写为:

foreach(var item in queue.GetConsumingEnumerable())
    Process(item);