Parallel.Invoke中如何捕获并抛出原始异常而非聚合异常？

当然可以拿到原始异常，甚至能尽可能让并行任务快速终止——咱们一步步来解决这个问题：

1. 先搞懂Parallel.Invoke抛出的异常类型 #

当Parallel.Invoke里的任务抛出异常时，它会把所有异常包装成**AggregateException**抛出，你看到的“One or more errors occurred”只是这个聚合异常的默认提示，里面其实藏着所有原始异常的细节。

2. 捕获并提取原始异常 #

你可以在try-catch里直接捕获AggregateException，然后通过它的InnerExceptions属性（或者用Flatten()方法处理嵌套的聚合异常）拿到所有原始异常。比如：

try
{
    Parallel.Invoke(
        () => CPUIntensiveMethod1(),
        () => CPUIntensiveMethod2()
    );
}
catch (AggregateException ae)
{
    // 提取第一个原始异常直接抛出（根据业务需求选择）
    throw ae.InnerExceptions[0];
    
    // 如果你需要处理所有异常，也可以遍历：
    // foreach (var ex in ae.Flatten().InnerExceptions)
    // {
    //     // 记录日志或收集异常信息用于UI展示
    // }
}

3. 让并行任务尽快终止（进阶优化） #

默认情况下，Parallel.Invoke会等待所有任务执行完成后才抛出聚合异常——哪怕其中一个任务已经报错。如果你想在第一个异常出现时就立刻终止所有并行任务，可以结合CancellationToken实现：

具体步骤： #

• 创建CancellationTokenSource，用来传递取消信号
• 把令牌传给每个CPU密集方法，在方法内部定期检查令牌是否已取消
• 当一个任务抛出异常时，立即触发取消信号，让其他任务停止执行

完整最小可复现示例（MCVE）： #

using System;
using System.Threading;
using System.Threading.Tasks;

class Program
{
    static void Main()
    {
        using var cts = new CancellationTokenSource();
        
        try
        {
            Parallel.Invoke(
                new ParallelOptions { CancellationToken = cts.Token },
                () => CPUIntensiveMethod1(cts.Token),
                () => CPUIntensiveMethod2(cts.Token)
            );
        }
        catch (AggregateException ae)
        {
            // 获取第一个原始异常，直接抛出给UI层
            var originalException = ae.Flatten().InnerExceptions[0];
            throw originalException;
        }
    }

    static void CPUIntensiveMethod1(CancellationToken token)
    {
        for (int i = 0; i < 100000000; i++)
        {
            // 定期检查取消信号，一旦收到就终止任务
            token.ThrowIfCancellationRequested();
            
            // 模拟CPU密集操作
            Math.Sqrt(i);
            
            // 模拟抛出特定异常
            if (i == 50000000)
            {
                throw new InvalidOperationException("方法1抛出的无效操作异常");
            }
        }
    }

    static void CPUIntensiveMethod2(CancellationToken token)
    {
        for (int i = 0; i < 100000000; i++)
        {
            token.ThrowIfCancellationRequested();
            
            // 模拟CPU密集操作
            Math.Pow(i, 3);
            
            // 模拟抛出另一种异常
            if (i == 70000000)
            {
                throw new ArgumentOutOfRangeException("方法2抛出的参数越界异常");
            }
        }
    }
}

4. 特殊情况：无法立即终止任务 #

如果你的CPU密集方法里没办法插入取消检查（比如调用的是第三方黑盒代码），那至少可以通过AggregateException拿到所有原始异常，然后在UI层展示具体的异常信息——比如把所有原始异常的消息拼接起来，或者选择第一个出现的异常展示给用户。

内容的提问来源于stack exchange，提问作者JacobIRR