C#并行循环中的异常处理（详解AggregateException在Parallel.ForEach中的聚合机制）

为什么需要异常聚合？

在串行循环中，一旦某次迭代抛出异常，循环会立即停止。但在并行环境中，多个任务可能同时运行。如果其中一个任务失败，其他任务可能仍在执行。为了不丢失任何异常信息，.NET 将所有抛出的异常收集起来，打包成一个 AggregateException 对象，在并行操作结束后统一抛出。

这就是 C#多线程异常聚合 的核心思想：确保你不会因为只捕获第一个异常而忽略其他潜在错误。

基础示例：Parallel.ForEach 中抛出异常

下面是一个简单的例子，演示在 Parallel.ForEach 中如何触发多个异常：

using System;using System.Collections.Generic;using System.Threading.Tasks;class Program{    static void Main()    {        var numbers = new List<int> { 1, 2, 0, 4, 5 };        try        {            Parallel.ForEach(numbers, num =>            {                if (num == 0)                    throw new InvalidOperationException("不能除以零！");                Console.WriteLine($"100 / {num} = {100 / num}");            });        }        catch (AggregateException ae)        {            Console.WriteLine($"捕获到 {ae.InnerExceptions.Count} 个异常：");            foreach (var ex in ae.InnerExceptions)            {                Console.WriteLine($"- {ex.Message}");            }        }    }}

在这个例子中，当遍历到数字 0 时，会抛出 InvalidOperationException。由于是并行执行，即使只有一个异常，它也会被包装进 AggregateException。如果有多个元素导致异常（比如加入另一个非法值），那么 InnerExceptions 集合中就会包含多个异常对象。

深入理解 AggregateException

AggregateException 是 .NET 提供的一个特殊异常类，用于封装多个内部异常（InnerExceptions）。你可以通过以下方式处理它：

• 遍历 InnerExceptions 查看所有错误
• 使用 Flatten() 方法将嵌套的 AggregateException 展平（适用于多层并行调用）
• 使用 Handle(Predicate<Exception>) 方法选择性地处理特定类型的异常

使用 Handle 方法过滤异常

catch (AggregateException ae){    // 只处理 InvalidOperationException，其他异常重新抛出    ae.Handle(ex =>    {        if (ex is InvalidOperationException)        {            Console.WriteLine($"已处理异常: {ex.Message}");            return true; // 表示已处理        }        return false; // 未处理，将重新抛出    });}

这种方式非常适合在 Parallel.ForEach异常处理 场景中实现精细化控制。

最佳实践建议

1. 始终用 try-catch 包裹并行循环，否则未处理的 AggregateException 会导致程序崩溃。
2. 记录所有 InnerExceptions，避免只关注第一个错误而忽略其他问题。
3. 在日志系统中，建议将每个内部异常单独记录，便于排查。
4. 避免在并行循环中抛出非必要异常，异常处理开销较大，影响性能。

总结

掌握 C#并行循环 中的异常聚合机制，是编写健壮多线程应用的关键。通过合理使用 AggregateException，你可以全面捕获并处理所有并发任务中的错误，提升程序的稳定性和可维护性。记住：并行不是“更快的串行”，它需要更严谨的错误处理策略。

关键词回顾：C#并行循环、Parallel.ForEach异常处理、AggregateException捕获、C#多线程异常聚合。