c# - 将C#ConcurrentBag <T>与多个生产者和一个消费者一起使用

我遇到了多个线程正在创建一个ICollection对象的情况。 ConcurrentBag似乎是最好的(？)解决方案，因为-1)每个线程将拥有自己的本地队列，并且2)线程不需要进行通信-它们是独立的。到目前为止，一切都很好，但是事实是我需要从该方法返回一个ISet(在所有生产者都终止之后)。即使当前的ConcurrentBag实例与是不同的(由于应用程序的逻辑得到保证)，我仍然需要将其转换为ISet，例如HashSet。在这一点上，不再有生产者。现在出现了真正的问题:

迭代ConcurrentBag时，调用线程是否将为不在线程本地队列中的每个项目获取锁？还是每个线程一次获取一个锁？另外，仅迭代bag和调用bag.Distinct()显式地，锁定方式之间的内部实现是否有所不同？

最佳答案

看一下ConcurrentBag的源代码:http://referencesource.microsoft.com/#System/sys/system/collections/concurrent/ConcurrentBag.cs,537a65e966c1c38d

遍历包会触发对FreezeBag的调用。此方法调用AcquireAllLocks，它浏览每个线程的队列并设置一个锁:

/// <summary>
/// local helper method to acquire all local lists locks
/// </summary>
private void AcquireAllLocks()
{
    Contract.Assert(Monitor.IsEntered(GlobalListsLock));

    bool lockTaken = false;
    ThreadLocalList currentList = m_headList;
    while (currentList != null)
    {
        // Try/Finally bllock to avoid thread aport between acquiring the lock and setting the taken flag
        try
        {
            Monitor.Enter(currentList, ref lockTaken);
        }
        finally
        {
            if (lockTaken)
            {
                currentList.m_lockTaken = true;
                lockTaken = false;
            }
        }
        currentList = currentList.m_nextList;
    }
}

它将为每个线程获取一次锁，而不是为每个项目获取一次。

迭代或调用Distinct都将调用GetEnumerator方法，因此没有什么区别。