C#的PLINQ的AggregateException怎么捕获？并行查询异常

try-catch

using System; using System.Linq; using System.Collections.Generic; using System.Threading;  public class PlinqExceptionHandling {     public static void Main(string[] args)     {         var numbers = Enumerable.Range(0, 10);          try         {             // 模拟一个会抛出异常的并行操作             var result = numbers.AsParallel().Select(num =>             {                 if (num % 3 == 0) // 模拟某些条件下的异常                 {                     Console.WriteLine($"线程 {Thread.CurrentThread.ManagedThreadId} 正在处理 {num}，即将抛出异常...");                     throw new InvalidOperationException($"处理数字 {num} 时出错！");                 }                 Console.WriteLine($"线程 {Thread.CurrentThread.ManagedThreadId} 正在处理 {num}，结果 {num * 2}");                 return num * 2;             }).ToList(); // ToList() 会强制执行查询并触发异常              Console.WriteLine("所有操作成功完成。");             foreach (var item in result)             {                 Console.WriteLine(item);             }         }         catch (AggregateException ae)         {             Console.WriteLine("n捕获到 AggregateException！");             // 遍历并处理所有内部异常             ae.Handle(ex =>             {                 if (ex is InvalidOperationException invalidOpEx)                 {                     Console.Error.WriteLine($"  处理 InvalidOperationException: {invalidOpEx.Message}");                     return true; // 表示这个异常已经被处理                 }                 else if (ex is OperationCanceledException cancelEx)                 {                     Console.Error.WriteLine($"  处理 OperationCanceledException: {cancelEx.Message}");                     return true; // 同样表示处理                 }                 // 如果返回 false，那么这个异常会被重新抛出（封装在新的AggregateException中）                 Console.Error.WriteLine($"  处理未知异常类型: {ex.GetType().Name} - {ex.Message}");                 return false;             });              // 也可以直接遍历 InnerExceptions             // foreach (var innerEx in ae.InnerExceptions)             // {             //     Console.Error.WriteLine($"  内部异常: {innerEx.GetType().Name} - {innerEx.Message}");             // }         }         catch (Exception ex)         {             Console.Error.WriteLine($"捕获到非 AggregateException 异常: {ex.GetType().Name} - {ex.Message}");         }          Console.WriteLine("n程序执行完毕。");     } }

// 假设 ae 是你捕获到的 AggregateException foreach (var innerEx in ae.InnerExceptions) {     if (innerEx is FormatException fEx)     {         // 处理格式错误         Console.Error.WriteLine($"数据格式错误：{fEx.Message}");     }     else if (innerEx is DivideByZeroException dbzEx)     {         // 处理除零错误         Console.Error.WriteLine($"发生了除零操作：{dbzEx.Message}");     }     else     {         // 处理其他未知类型的异常         Console.Error.WriteLine($"发现未知错误类型 {innerEx.GetType().Name}: {innerEx.Message}");     }     // 可以在这里记录日志、发送通知等 }

AggregateException.Handle()

Func<Exception, bool>

ae.Handle(ex => {     if (ex is InvalidOperationException invalidOpEx)     {         Console.Error.WriteLine($"业务逻辑错误：{invalidOpEx.Message}");         return true; // 我处理了业务逻辑错误，不需要再抛出     }     // 对于 OperationCanceledException，通常我们也认为它是一种正常的中断，可以处理掉     if (ex is OperationCanceledException)     {         Console.WriteLine("操作被取消。");         return true;     }     // 其他类型的异常，我可能暂时无法处理，或者希望它继续向上抛出     return false; // 不处理，让它继续冒泡 });

catch (Exception ex)

ex

Message

CancellationTokenSource

CancellationToken