即使我锁定它，我的列表也不是线程安全的

Question

我得到：

"collection was modified enumeration operation may not execute" at this line:

foreach (Message msg in queue)

过了一会儿。

我必须使用 .NET 2.0。

我对名为“queue”的私有List进行的两个操作如下：

// 1st function calls this
lock (queue)
{
      queue.Add(msg);
}

// 2nd function calls this
lock (queue)
{
      using (StreamWriter outfile = new StreamWriter("path", true)
      {
             foreach (Message msg in queue) // This is were I get the exception after a while)
             {
                  outfile.WriteLine(JsonConvert.SerializeObject(msg)); 
             }

              queue = new List<Message>();
      }
}

我做错了什么？

Answer 1

（下面；好吧，我想不出会导致这种情况的竞争条件......但是：谁知道......）

首先，您真的需要寻找与列表对话的其他代码；问题不在您发布的代码中。我怎么知道这个？因为在您枚举 (foreach (Message msg in queue)) 时，您在 queue 上有一个锁，而我们没有对锁对象的重新分配（非常狡猾，但不相关）做任何事情。

对于这个foreach 错误意味着其他东西正在改变列表。首先要做的事情很简单，就是重命名列表字段。如果其他代码触及列表，这将非常快速地向您显示。还要检查您是否从不公开此代码之外的列表，即从不从任何地方return queue;。

问题似乎不在您显示的代码中。重新分配锁定对象是不好的做法，您不应该这样做 - 但是：我看不到实际破坏它的场景（显示代码）。

---

列表不是这里最好的模型，重新分配一个锁对象不是一个好主意。 要是有一个内置类型来表示队列就好了...

private readonly Queue<Message> queue = new Queue<Message>();
...
lock (queue) {
    queue.Enqueue(msg);
}

// 2nd function calls this
lock (queue) {
    if(queue.Count == 0) continue; // taken from comments

    using (StreamWriter outfile = new StreamWriter("path", true) {
        while(queue.Count != 0) {
            Message msg = queue.Dequeue();
            outfile.WriteLine(JsonConvert.SerializeObject(msg)); 
        }
    }
}

无需清除，因为 Dequeue 本质上有效地做到了这一点。

Answer 2

lick 语句使用的参数应该是只读的。看到这个link

使用readonly private object 而不是queqe

代码应该是

eadonly object _object = new object();
// 1st function calls this
lock (_object)
{
      queue.Add(msg);
}

// 2nd function calls this
lock (_object)
{
      using (StreamWriter outfile = new StreamWriter("path", true)
      {
             foreach (Message msg in queue) // This is were I get the exception after a while)
             {
                  outfile.WriteLine(JsonConvert.SerializeObject(msg)); 
             }

              queue = new List<Message>();
      }
}