c# 在LINQ查询中使用并行AsParallel()的注意事项_技术教程

AsParallel() 仅在大数据量、计算密集且元素处理独立时才可能提升性能；小集合或含副作用、不支持操作符（如TakeWhile）会失效或降级，并发需避免共享变量，应优先用Aggregate()等线程安全方式。

AsParallel() 不会自动让所有 LINQ 查询变快

并行执行不是银弹，AsParallel() 只在数据量大、计算密集、且各元素处理相互独立时才可能带来收益。小集合（比如 HttpClient）、或本身已含锁/共享状态的逻辑，反而因线程调度、同步开销和分区成本而显著变慢。

默认分区策略（Partitioning）可能不均衡，尤其对非索引结构（如 LinkedList 或自定义枚举器）
查询中若含 ToList()、ToArray() 等强制立即执行操作，会触发完整并行计算，但后续链式调用（如再接 .Where()）仍走并行路径——这点常被误认为“断掉了并行”
调试模式下并行查询堆栈混乱，异常位置难定位；建议生产环境开启 PLINQ 的异常聚合控制（见下一点）

异常处理必须显式配置 `WithExecutionMode(ParallelExecutionMode.ForceParallelism)` 和 `WithMergeOptions()`

PLINQ 默认在检测到潜在问题（如某些操作符不支持并行）时自动回退到串行执行，且异常会被包装为 AggregateException。若不干预，你可能收不到预期异常，或无法区分哪个元素出错。

用 .WithExecutionMode(ParallelExecutionMode.ForceParallelism) 强制并行，避免静默降级
用 .WithMergeOptions(ParallelMergeOptions.NotBuffered) 让结果流式输出，减少内存堆积（尤其配合 foreach 遍历时）
捕获 AggregateException 后，需遍历 .InnerExceptions 才能拿到原始错误，例如空引用或除零异常

try
{
    var result = source.AsParallel()
        .WithExecutionMode(ParallelExecutionMode.ForceParallelism)
        .WithMergeOptions(ParallelMergeOptions.NotBuffered)
        .Select(x => 100 / x) // 可能抛 DivideByZeroException
        .ToList();
}
catch (AggregateException ex)
{
    foreach (var inner in ex.InnerExceptions)
    {
        Console.WriteLine(inner.Message); // 打印具体哪个 x 导致失败
    }
}

共享变量和副作用是最大雷区

PLINQ 会把数据分块分发到多个线程执行，任何在 Select、Where 等委托中修改外部变量（如 int counter = 0; ... .Select(x => { counter++; return x * 2; })）的行为都是未定义的：计数不准、竞态、甚至死锁都可能发生。