c#

PLINQ在C#中如何处理异常

小樊
84
2024-08-21 22:58:29
栏目: 编程语言

在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异常。

0
看了该问题的人还看了