从线程更新的集合中获取对象列表

Question

我有一个线程正在更新的项目字典。我想要一个方法使用另一个线程获取更新的项目列表。

像这样：

    internal List<string> GetListOfEntities()
    {            
        List<string> listOfEntities = new List<string>();
        foreach (string entityName in ModelFacade._totalListOfStkObjects.Keys)
        {
            listOfEntities.Add(entityName);
        }
        return listOfEntities;
    }

ModelFacade._totalListOfStkObjects 是线程正在更新的集合。我不断收到异常：“集合已修改；枚举操作可能无法执行。”；我尝试将 _totalListOfStkObjects 复制到本地集合并在 GetListOfEntities() 中迭代它..但我得到了相同的错误..？

有什么帮助吗？

沃夫加Pro

Answer 1

不会有保证线程安全的方式来访问字典。最好的选择是更改代码，以便不共享集合，或者在访问时锁定字典：

object dictLock = new object();

internal List<string> GetListOfEntities()
{            
    lock (dictLock)
    {
        return ModelFacade._totalListOfStkObjects.Keys.ToList();
    }
}

确保在另一个线程中修改字典时也锁定字典。

Answer 2

如果您使用的是 .NET 4，请将 Dictionary 更改为 ConcurrentDictionary。这是一个简单的示例，可以模拟您的问题并解决它。

class DataItem
{
    public int Data { get; set; }
    public bool IsDirty { get; set; }
}

var data = new ConcurrentDictionary<string, DataItem>();
Thread addingItems = new Thread(() =>
    {
       for (int i = 0; i < 10000; i++)
       {
           data.TryAdd("data " + i, new DataItem { Data = i, IsDirty = true });
           Thread.Sleep(100);
       }
    });
Thread fetchingItems = new Thread(() =>
    {
        int count = 0;
        while (count < 100)
        {
            foreach (var item in data)
            {
                if (item.Value.IsDirty)
                {
                    Console.WriteLine(item.Key + " " + item.Value);
                    item.Value.IsDirty = false;
                    count++;
                }
            }
        }
    });
addingItems.Start();
fetchingItems.Start();

Answer 3

您可以将字典包装在线程安全的单例类中。这应该为 Dictionary 提供 ConcurrentDictionary 的所有功能。引用字典应该只需要一层额外的间接层。

参考：

Singleton.Instance.myDictionary.Add(1, "Hello World");

声明：

public sealed class Singleton
{
    private static volatile Singleton instance;
    private static object syncRoot = new Object();
    public Dictionary<int, string> myDictionary = new Dictionary<int, string>();

    private Singleton() {}

    public static Singleton Instance
    {
        get
        {
            if (instance == null)
            {
                lock (syncRoot)
                {
                    if (instance == null)
                        instance = new Singleton();
                }
            }
            return instance;
        }
    }
}

此处了解有关 C# 中单例模式的更多信息。请注意，此链接上的模式与我的示例代码之间只有一处区别。