如何合并Parallel.ForEach各线程生成的冲突检测列表

你的场景属于CPU密集型的两两元素校验，完全可以通过带线程本地存储的Parallel.For实现目标逻辑，核心优势是全程几乎无锁竞争，性能远高于直接对共享集合加锁写入的方案。 #

逻辑匹配说明 #

完全对齐你提出的并行要求：

• 外层循环按索引范围拆分到不同工作线程执行
• 每个线程独立初始化、维护自己私有的冲突列表，校验过程中写入私有列表不需要任何锁
• 所有线程任务执行完成后，统一把各线程的私有冲突列表合并为最终的全局列表

可直接替换的实现代码 #

using System.Threading.Tasks;

// 初始化全局最终冲突列表
List<Conflict> finalConflicts = new List<Conflict>();

// 可根据实际硬件情况调整并行度，默认用CPU逻辑核心数即可
ParallelOptions parallelSetting = new ParallelOptions
{
    MaxDegreeOfParallelism = Environment.ProcessorCount
};

Parallel.For(
    0, 
    lstComponents.Count, 
    parallelSetting,
    // 每个工作线程启动时，初始化自己私有的冲突列表
    () => new List<Conflict>(),
    // 单个索引i的处理逻辑
    (i, loopState, threadLocalConflictList) =>
    {
        Element currentComponent = lstComponents[i];
        // 内层j循环保持顺序执行即可，不需要并行，避免任务粒度过细带来的调度开销
        for (int j = i + 1; j < lstComponents.Count; j++)
        {
            Element compareComponent = lstComponents[j];
            bool hasConflict = false;
            Conflict conflictResult = null;

            // 替换为你原有的多步冲突校验逻辑
            // [multiple verification...]

            if (hasConflict)
            {
                // 写入线程私有列表，无锁无竞争
                threadLocalConflictList.Add(conflictResult);
            }
        }
        // 将当前线程的私有列表传递给同线程的下一次循环
        return threadLocalConflictList;
    },
    // 单个工作线程处理完所有分配的任务后，执行结果合并
    (threadLocalConflictList) =>
    {
        // 仅在合并时加一次锁，每个线程只会执行一次该逻辑，锁开销极低
        lock (finalConflicts)
        {
            finalConflicts.AddRange(threadLocalConflictList);
        }
    }
);

return finalConflicts;

关键优化&注意点 #

• 不要对内层j循环做并行：外层循环已经将任务均匀拆分到各线程，内层并行会导致任务粒度过细，调度开销远大于计算收益，还容易破坏j > i的去重逻辑，出现重复比对
• 避免直接写入共享集合：哪怕用ConcurrentBag这类线程安全集合，每次写入都存在同步开销，在计算量大的场景下性能比线程私有列表最后合并低30%以上
• 优先用索引器访问元素：如果lstComponents是List<T>类型，直接用lstComponents[i]访问比ElementAt()方法快很多，如果是其他可枚举类型，建议提前用.ToList()转换成支持快速索引的列表
• 校验逻辑不要修改共享状态：冲突校验环节如果需要读取外部数据，确保读取的是不可变的只读数据，否则仍会出现线程安全问题

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