PLINQ在C#中如何处理异常

在PLINQ中，异常处理的方式与普通的LINQ操作类似。当在PLINQ查询中发生异常时，异常将被封装在AggregateException对象中，并通过调用Handle方法来处理异常。

以下是一个处理异常的示例代码：

try {     var query = from num in numbers.AsParallel()                 where num % 2 == 0                 select 100 / num;      query.ForAll(Console.WriteLine); } catch (AggregateException ex) {     foreach (var innerException in ex.InnerExceptions)     {         Console.WriteLine($"Exception: {innerException.Message}");     } } 

在上面的示例中，如果在计算100除以某个数字时抛出异常，则异常将被封装在AggregateException对象中，并通过遍历InnerExceptions属性来访问所有的内部异常。

另外，可以通过使用WithCancellation方法来提供一个CancellationToken对象，以便在取消操作时处理异常。

var cts = new CancellationTokenSource(); cts.CancelAfter(500); // 取消操作在500毫秒后执行  try {     var query = from num in numbers.AsParallel().WithCancellation(cts.Token)                 where num % 2 == 0                 select 100 / num;      query.ForAll(Console.WriteLine); } catch (OperationCanceledException) {     Console.WriteLine("Query was cancelled."); } 

在上面的示例中，如果在取消操作之前发生异常，则会抛出OperationCanceledException异常。