multithreading - 对于单生产者，单消费者应该使用BlockingCollection还是ConcurrentQueue？

Question

对于单生产者，单消费者应该使用BlockingCollection还是ConcurrentQueue？

顾虑:

我的目标是一次最多提取100个项目，并将它们作为批次发送到下一步。

如果我使用ConcurrentQueue，则在没有任何工作要做时，我必须手动使其进入休眠状态。否则，我会浪费CPU周期进行旋转。

如果我使用BlockingQueue并且我只有99个工作项目，则它可能会无限期地阻塞，直到第100个项目到达为止。

http://msdn.microsoft.com/en-us/library/system.collections.concurrent.aspx

Answer 1

您可能无法使用其中任何一个。尽管就像您说的那样，如果使用ConcurrentQueue，那么您将不得不在队列为空时执行旋转等待。如果您期望生产者和消费者之间的时差很短，那可能还不错。最后，我认为您会发现BlockingCollection更适合您的情况。毕竟，它是生产者-消费者模式选择的数据结构。您可以通过两种不同的方法来解决不确定的等待问题。

将标记值用作使用者中的停止指示符。插入队列中的null值在这里可以很好地工作。

利用CancellationToken机制来取消阻止Take方法。