如何创建不重复的ConcurrentQueue？

Question

我需要一个不允许重复的并发集合（在 BlockingCollection 中作为生产者/消费者使用）。 我不需要严格的元素顺序。 另一方面，我想最小化元素在集合中“存活”的最长时间。即收集不能是后进先出的，理想情况下应该是先进先出的。

好吧，我会说我需要不允许重复的 ConcurrentQueue ，但是不允许重复的 ConcurrentBag 也可能有效。

为什么 C# 不包含类似的东西并且可能已经有人创建了它？

这个问题是我上一个问题 什么类型的 IProducerConsumerCollection的结果;用于我的任务？

Answer 1

没有内置的 .Net 库可以将这组规则组合到一个集合中。您有以下三种选择：

1. 编写自己的集合类
2. 使用两个集合： 编写一个自定义类，该类使用一个 ConcurrentQueue 和任何自动检查重复项的基于 Set 的集合；已添加到 Set 运行，如果成功，则添加到 ConcurrentQueue；成功时，每次添加/删除都会添加到两个集合中
3. 使用 ConcurrentQueue，但会迭代整个列表，检查是否有重复

最后两个效率不高（一个使用内存，另一个使用 CPU、I/O、锁定）并且比较混乱因为需要显式锁定，但可以完成任务。它们的实施速度会更快，但如果权衡不能满足您的要求，您将不得不选择选项#1。

Answer 2

好吧，如果您严格希望没有重复项，则需要“集合”。例如，NHibernate 使用 Iesi.Collections 来提供此类功能。使用 Iesi，您可以围绕提供的“Set”类（DictionarySet、HashSet、SortedSet）构建您自己的功能。来源：http://www.codeproject.com/KB/recipes/sets.aspx

Answer 3

您可以简单地使用 ConcurrentQueue 并在调用 Enqueue 之前通过调用 ConcurrentQueue.Contains 方法检查数据是否在队列中。我猜测 Contains 扩展方法已经得到了相当好的优化。

编辑：
正如其他人所指出的，要实现此目的，您必须在 Contains 方法和 Enqueue 方法周围使用锁定机制，例如互斥体等像这样：

get mutex
if not Contains<>
{
    Enqueue
}
release mutex