迭代循环内多异步调用：LoadAsync中任一任务失败时终止所有任务

嘿，这个需求其实挺常见的——并行跑一批异步任务，只要有一个崩了，立刻叫停剩下的所有任务。我来给你拆解下怎么在你的LoadAsync方法里实现这个逻辑，保证贴合你要的“任一失败即终止”的要求：

核心思路 #

本质上就是用**取消令牌（CancellationToken）**来实现全局控制：启动所有异步任务后，实时监听每个任务的状态，一旦发现有任务失败，立刻触发取消信号，让其他正在执行的任务停止操作。

实现方案一：用ContinueWith监听任务失败 #

这种方式比较直观，适合大多数场景：

public async Task LoadAsync(IEnumerable<MyItem> items)
{
    // 创建取消令牌源，用来发送取消信号
    using var cancellationTokenSource = new CancellationTokenSource();
    var runningTasks = new List<Task>();

    foreach (var item in items)
    {
        // 给每个任务传入取消令牌，确保能响应取消指令
        var task = ProcessSingleItemAsync(item, cancellationTokenSource.Token);
        runningTasks.Add(task);

        // 异步监听任务失败状态，一旦失败立刻触发取消
        _ = task.ContinueWith(failedTask =>
        {
            if (failedTask.IsFaulted)
            {
                cancellationTokenSource.Cancel();
            }
        }, TaskContinuationOptions.OnlyOnFaulted);
    }

    try
    {
        // 等待所有任务完成（或被取消）
        await Task.WhenAll(runningTasks);
    }
    catch (OperationCanceledException)
    {
        // 找到第一个失败的任务，把原始异常抛给调用方
        var firstFailedTask = runningTasks.First(t => t.IsFaulted);
        ExceptionDispatchInfo.Capture(firstFailedTask.Exception.InnerException).Throw();
    }
}

// 你实际的单个元素异步加载方法，必须支持取消
private async Task ProcessSingleItemAsync(MyItem item, CancellationToken cancellationToken)
{
    // 在关键步骤检查取消令牌，确保能及时响应取消
    cancellationToken.ThrowIfCancellationRequested();

    // 替换成你的实际异步逻辑，比如加载数据、调用API等
    await YourActualAsyncLoadOperation(item, cancellationToken);
}

关键细节说明 #

• CancellationTokenSource：相当于一个“开关”，调用Cancel()后，所有持有对应令牌的任务都会收到取消通知。
• ContinueWith：专门监听任务失败的情况（TaskContinuationOptions.OnlyOnFaulted），不用等所有任务完成就立刻触发取消，效率很高。
• 处理取消异常：Task.WhenAll在收到取消信号后会抛出OperationCanceledException，这时候我们要找到真正失败的任务，把它的原始异常抛出去，让调用方知道到底哪里出问题了，而不是只看到“任务被取消”。

实现方案二：用Task.WhenAny循环监控 #

如果想要更实时地响应失败（比如第一个任务失败后立刻终止，不等其他任务的ContinueWith触发），可以用Task.WhenAny循环：

public async Task LoadAsync(IEnumerable<MyItem> items)
{
    using var cancellationTokenSource = new CancellationTokenSource();
    // 把所有任务放到集合里
    var remainingTasks = new HashSet<Task>(
        items.Select(item => ProcessSingleItemAsync(item, cancellationTokenSource.Token))
    );

    while (remainingTasks.Count > 0)
    {
        // 等待第一个完成的任务
        var completedTask = await Task.WhenAny(remainingTasks);
        remainingTasks.Remove(completedTask);

        // 如果这个任务失败了，立刻取消所有剩下的任务
        if (completedTask.IsFaulted)
        {
            cancellationTokenSource.Cancel();
            // 等待剩下的任务处理完取消逻辑（可选，根据需求决定）
            await Task.WhenAll(remainingTasks);
            // 抛出原始失败异常
            ExceptionDispatchInfo.Capture(completedTask.Exception.InnerException).Throw();
        }
    }
}

方案优势 #

这种方式会在第一个失败任务完成的瞬间就触发取消，比方案一的响应速度更快，适合对终止时机要求很高的场景。

必须注意的点 #

1. 你的异步方法必须支持取消：不管是自己写的ProcessSingleItemAsync，还是调用第三方异步API，一定要把CancellationToken传进去，并且在关键步骤调用cancellationToken.ThrowIfCancellationRequested()，否则取消信号可能无效。
2. 不要忽略取消后的清理：如果任务涉及资源占用（比如文件句柄、数据库连接），取消后要确保资源被正确释放，最好用using语句或者在catch (OperationCanceledException)里做清理。
3. 异常处理要清晰：一定要把原始的失败异常抛出去，而不是只返回“任务被取消”，这样调用方才能排查问题。

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