Parallel.ForEach多线程场景下lock关键字失效问题排查请求

嘿，我来帮你捋捋这个Parallel.ForEach的线程安全问题！你遇到的“线程覆盖属性”问题，加了lock还没解决，大概率是lock的用法不对，或者共享状态的访问没覆盖全，咱们一步步排查：

lock的本质是锁定同一个引用对象，如果你的锁对象不对，等于白加：

• ❌ 错误示例1：锁了局部对象，每个线程都创建新锁，完全起不到同步作用

  Parallel.ForEach(dataItems, item =>
  {
      // 每个线程都会new一个新object，锁等于无效
      lock (new object())
      {
          SharedProperty = CalculateValue(item);
      }
  });
  

• ❌ 错误示例2：锁了this（如果是实例类），多个实例会有不同的锁，跨实例的线程还是会冲突
• ✅ 正确做法：用类级别唯一的静态只读对象当锁

  // 类里定义全局唯一的锁对象
  private static readonly object _syncLock = new object();
  private static int _sharedProperty;
  
  Parallel.ForEach(dataItems, item =>
  {
      var evalResult = DifferentiatedEvaluation(item);
      lock (_syncLock)
      {
          // 这里的共享属性读写才是真正同步的
          _sharedProperty = evalResult;
      }
  });
  

别只盯着Parallel.ForEach里的代码！如果你的共享属性是public的，或者在其他地方（比如类的其他方法、外部类）也有读写操作，这些地方没加锁的话，照样会出现覆盖问题：

• 比如属性的getter如果涉及计算（不是单纯返回字段），也要加锁；
• 确保所有读写共享状态的代码都被同一个_syncLock包裹。

你提到“部分数据需要差异化评估”，如果多个线程都在修改同一个属性，最后只会保留最后一个线程的结果——这真的是你想要的吗？
如果是要收集所有差异化评估的结果，而不是覆盖单值，建议用线程安全集合替代共享属性：

// 用ConcurrentBag收集每个线程的评估结果，无需额外lock
var evaluationResults = new ConcurrentBag<YourResultType>();

Parallel.ForEach(dataItems, item =>
{
    if (NeedDifferentiatedEval(item))
    {
        var result = DoDifferentiatedEval(item);
        evaluationResults.Add(result);
    }
    else
    {
        var result = DoNormalEval(item);
        evaluationResults.Add(result);
    }
});

// 最后统一处理所有结果
ProcessAllResults(evaluationResults);

如果还是找不到问题，给共享属性的setter加个断点，查看调用栈：

• 看看是哪个线程在修改属性，有没有没经过lock的调用；
• 可以临时给每个线程加个标记（比如Thread.CurrentThread.ManagedThreadId），打印日志看看属性被哪些线程修改了，时序是怎样的。

内容的提问来源于stack exchange，提问作者user9393635