枚举和修改对象的 ConcurrentBag 的最有效方法

Question

我有一个 ConcurrentBag 对象，我想对其进行以下操作：

1. 使用 where 过滤枚举所有项目。
2. 为每个项目检查一些属性，并根据值进行一些方法调用。方法调用后，最好从包中取出物品。
3. 修改一些属性的值并保存到包中。

所以基本上我需要以下内容：

   foreach (var item in myBag.Where(it => it.Property1 = true))
        {
            
            if (item.Property2 = true)
            {
                SomeMethodToReadTheItem(item);
                //it's better to remove this item from the bag here, but 
                //there is a permeance hit, then just leave it.
            }
            else
            {
                item.Property3=  "new value";
                //now how do I save the item back to the bag?
            }
            
        }

因为它应该以线程安全的方式完成。我知道对 ConcurrentBag 的枚举实际上是对真实包的“快照”，但是使用 where 子句过滤器怎么样？我应该做一个 ToList 以防止它形成一个新的“快照”吗？ 此外，如果您想修改一个特定项目，您只需 bag.TryTake(out item)。但是既然我已经拿到了枚举中的item，是不是又要“拿”一次呢？

任何解释/评论/示例都会非常有用。

谢谢。

Answer 1

我将尝试回答您问题的特定部分而不涉及性能。

首先，Where 方法将IEnumerable<T> 作为它的第一个参数，并且它本身将遍历将调用GetEnumerator() 一次的可枚举，因此您将只拍摄底层ConcurrentBag 的快照。

其次，您的代码的线程安全性不是很清楚，您的其余代码中可能存在一些未指定的隐含保证。例如，您有一个ConcurrentBag，因此您的集合是线程安全的，但是您修改该集合中包含的项目而无需任何线程同步。如果有其他代码运行相同的方法或在另一个方法中同时读取/修改ConcurrentBag 中的项目，那么您可能会看到数据竞争。

请注意，如果您已经拥有对该项目的引用，则无需调用TryTake，因为它只会返回相同的引用。

Answer 2

我建议您只创建一个新列表，如果使用 WHERE 过滤器，请将其添加到此新列表中。 它看起来像这样：

List<T> myNewList = new List<T>();
foreach (var item in myBag.Where(it => it.Property1))
    {
        if (!item.Property2)
        {
            myNewList.Add(item);
        }            
    }

注意“！”