0

做了一个小例子来选择多线程环境中频繁更新字典的最佳方案。然后观察到“奇怪的”迭代行为。

using System;
using System.Collections.Generic;
using System.Threading;

namespace DictionaryTest
{
    class Program
    {
        static int _n;
        static Dictionary<int, string> _dict = new Dictionary<int, string>();

        static void Main(string[] args) {
            for (int i = 0; i < 50; i++) _dict[i] = "FIRST";

            new Thread(ReadDict).Start();
            Thread.Sleep(30);

            // CASE A, Throws exception AS EXPECTED.
            //_dict.Clear();

            // CASE B, ReadDict continues iterate on old dictionary values!!!???
            //_dict = new Dictionary<int, string>();

            // CASE C
            UpdateDict();
            ReadDict();

            Console.ReadKey();
        }

        private static void ReadDict() {
            // Read Method X
            // (continues iterate on old dictionary values!!!???)
            //
            foreach (var kvp in _dict) {
                Thread.Sleep(3);
                Console.WriteLine("{0,3} {1,4} {2,6} :{3,5} Method X", Interlocked.Increment(ref _n), kvp.Key, kvp.Value, Thread.CurrentThread.ManagedThreadId);
            }

            // Read Method Y
            //
            //for (int i = 0; i < 50; i++) {
            //    Thread.Sleep(3);
            //    Console.WriteLine("{0,3} {1,4} {2,6} :{3,5} Method Y", Interlocked.Increment(ref _n), i, _dict[i], Thread.CurrentThread.ManagedThreadId);
            //}
        }

        private static void UpdateDict() {
            var tmp = new Dictionary<int, string>();
            for (int i = 0; i < 50; i++) tmp[i] = "SECOND";
            _dict = new Dictionary<int, string>(tmp);
        }
    }
}

组合：

  1. 案例 A 和（方法 X 或方法 Y） - 按预期抛出异常！
  2. 案例 B 和方法 X - 继续迭代旧字典值？？？
  3. 案例 C 和方法 X - 继续迭代旧字典值？？？
  4. 案例 C 和方法 Y - 仅迭代预期的更新值！

循环是否会foreach获取静态 Dictionary 成员的某种内部快照？如果是这样，CASE A 也应该工作，但它没有。
有人可以解释导致这种奇怪行为的原因吗？

编辑：

尽管使用了 ConcurrentDictionary 和代码锁定，但基本上我的问题是关于字典更新方法之间的差异：将字典的新副本分配为全新的对象或更好地迭代某些集合并使用 dict[key]=myObject 方法单独更新新值？我不需要保留对值对象的引用，只需替换它。

4

1 回答 1

2

字典不是线程安全的。对于线程安全字典，使用

ConcurrentDictionary<int, string>

它可从命名空间 System.Collections.Concurrent 获得；

请参阅以下有关并发字典的优秀教程。

http://arbel.net/2013/02/03/best-practices-for-using-concurrentdictionary/

编辑：

我相信部分问题是即使使用并发字典，您仍然不是线程安全的，因为您的更新方法没有使用并发字典线程安全操作方法。以下尊重集合上的锁定。

private static void UpdateDict()
{
    for (int i = 0; i < 50; i++)
    {
         _dict.AddOrUpdate(i, _ => "SECOND", (i1, s) => "SECOND");
    }    
}

您应该会发现这会保留字典。我在索引器上有错字。现在可以正确读取您所期望的内容。

于 2013-10-08T15:09:00.460 回答