嵌套Parallel.For中线程本地BigInteger变量聚合异常问题解析

我把嵌套顺序for循环重构为嵌套Parallel.For循环，遵循了推荐的并行模式并加了锁，但最终聚合结果远低于顺序执行的结果。排查后发现问题出在BigInteger的错误使用上：针对BigInteger类型，必须使用++运算符或BigInteger.Add()方法进行累加计算。

关键原因 #

BigInteger是不可变值类型，直接对变量赋值修改不会产生预期的累加效果。如果错误地用普通赋值方式更新，线程本地的子累加值无法正确累积，最终导致全局聚合结果偏小。

正确实现示例 #

internal static class Program
{
    static readonly object lockObj = new object();
    static void Main()
    {
        // 预期结果：575
        NestedLoopAggregationTest();
    }

    private static void NestedLoopAggregationTest()
    {
        BigInteger totalSequential = 0;
        BigInteger totalRecommendedPattern = 0;

        const int iEnd1 = 5;
        const int iEnd2 = 10;
        const int iEnd3 = 15;

        // 顺序执行的基准实现
        for (int iCn1 = 1; iCn1 <= iEnd1; iCn1++)
        {
            for (int iCn2 = 1; iCn2 <= iEnd2; iCn2++)
            {
                for (int iCn3 = iCn2 - 1; iCn3 <= iEnd3; iCn3++)
                {
                    totalSequential++;
                }
            }
        }

        // 正确的并行实现
        Parallel.For(1, iEnd1 + 1, iCn1 =>
        {
            Parallel.For(1, iEnd2 + 1, iCn2 =>
            {
                Parallel.For<BigInteger>(iCn2 - 1, iEnd3 + 1, 
                    // 线程本地变量初始化
                    () => 0, 
                    // 迭代时更新线程本地累加值
                    (iCn3, state, subtotal) =>
                    {
                        // 正确方式：用BigInteger.Add或++运算符
                        subtotal = BigInteger.Add(subtotal, 1);
                        // 也可以写成 subtotal++;
                        return subtotal;
                    }, 
                    // 合并线程本地值到全局变量（加锁保证线程安全）
                    subtotal =>
                    {
                        lock (lockObj)
                        {
                            totalRecommendedPattern = BigInteger.Add(totalRecommendedPattern, subtotal);
                        }
                    });
            });
        });

        MessageBox.Show($"{totalSequential}{Environment.NewLine}{totalRecommendedPattern}");
    }           
}

核心要点 #

• 使用线程本地变量存储每个并行线程的子累加值，避免频繁的锁竞争
• 更新BigInteger时必须用BigInteger.Add()或++运算符，利用其不可变类型的正确更新逻辑
• 合并全局结果时通过锁保证线程安全，避免并发写入冲突

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