C#中任务列表的即时异常处理方案咨询

方法一：给每个Task绑定故障专属的延续任务 #

给每个创建的Task单独添加ContinueWith，指定TaskContinuationOptions.OnlyOnFaulted，这样一旦该任务抛出异常，就会立刻执行延续逻辑，无需等待所有任务完成。

// 存储所有任务的列表
List<Task> taskList = new List<Task>();

// 获取UI线程同步上下文（WinForms/WPF等UI场景必备）
var uiContext = SynchronizationContext.Current;

foreach (var item in someItems)
{
    var currentItem = item; // 规避闭包捕获循环变量的常见问题
    var task = Task.Run(() =>
    {
        // 调用存储过程方法
        ExtractDataSetCode_Query(currentItem);
    });

    // 绑定仅在任务故障时触发的延续逻辑
    var faultHandler = task.ContinueWith(faultedTask =>
    {
        // 提取真实异常（存储过程抛出的通常是InnerException）
        var exception = faultedTask.Exception?.InnerException ?? faultedTask.Exception;
        string errorMsg = $"处理项 {currentItem} 时出错: {exception.Message}";
        
        // 切换回UI线程通知用户（非UI场景可直接处理）
        uiContext?.Post(_ =>
        {
            MessageBox.Show(errorMsg);
            // 或更新UI控件，比如添加错误提示到列表
        }, null);

    }, TaskContinuationOptions.OnlyOnFaulted);

    taskList.Add(task);
}

// 保留原有逻辑：等待所有任务完成后执行全成功分支
await Task.WhenAll(taskList);
DoSomethingWhenAllSuccess();

注意点 #

• 循环中必须捕获当前迭代的变量（currentItem = item），否则所有任务会引用最后一个循环项。
• UI场景下必须通过SynchronizationContext切换线程，否则直接操作UI会触发跨线程异常。
• ContinueWith默认在后台线程执行，非UI操作可直接处理。

方法二：在Task内部直接捕获异常 #

更直接的方式是在Task执行逻辑内部用try-catch包裹目标方法，异常抛出时立刻在任务内处理并通知用户。

List<Task> taskList = new List<Task>();
var uiContext = SynchronizationContext.Current;

foreach (var item in someItems)
{
    var currentItem = item;
    var task = Task.Run(async () =>
    {
        try
        {
            ExtractDataSetCode_Query(currentItem);
        }
        catch (Exception ex)
        {
            string errorMsg = $"处理项 {currentItem} 时出错: {ex.Message}";
            
            // 即时通知用户
            uiContext?.Post(_ =>
            {
                MessageBox.Show(errorMsg);
            }, null);
            
            // 可选：重新抛出异常，让Task.WhenAll感知到故障，阻止全成功分支执行
            throw;
        }
    });

    taskList.Add(task);
}

try
{
    await Task.WhenAll(taskList);
    DoSomethingWhenAllSuccess();
}
catch (AggregateException ex)
{
    // 捕获所有未被内部处理的异常（如果上面选择抛出的话）
    // 可做统一故障记录，按需处理
}

优势 #

逻辑内聚，无需额外绑定延续任务，适合故障处理规则明确的场景。

关键注意事项 #

• 线程安全：如果多个任务同时更新共享资源或UI，需用lock或线程安全集合保证操作安全。
• 异常传播：若需要Task.WhenAll感知故障（跳过全成功分支），需在捕获后重新抛出异常；否则可忽略抛出，任务会标记为完成状态。
• 资源清理：ExtractDataSetCode_Query若占用数据库连接等资源，需在finally块中统一清理，避免资源泄漏。

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