如何修改Task.WhenAny行为使其返回首个成功完成的任务？

当然有办法实现这个需求！Task.WhenAny确实会返回第一个完成的任务（不管成功还是失败），但我们可以自己封装一个方法，专门筛选出第一个成功完成的任务。下面给你两种常用的实现思路：

方法一：循环筛选完成的任务 #

这种方法最直观，我们不断调用Task.WhenAny，每次拿到完成的任务后检查它是否成功——如果成功就直接返回；如果失败，就把它从待检查的任务列表中移除，继续等待剩下的任务。

针对无返回值的Task：

public static async Task<Task> WhenFirstSuccessful(IEnumerable<Task> tasks)
{
    var remainingTasks = tasks.ToList();
    while (remainingTasks.Count > 0)
    {
        var completedTask = await Task.WhenAny(remainingTasks);
        if (completedTask.Status == TaskStatus.RanToCompletion)
        {
            return completedTask;
        }
        // 移除失败的任务，继续等待剩下的
        remainingTasks.Remove(completedTask);
    }
    // 所有任务都失败时，抛出异常（你也可以根据需求返回null或其他结果）
    throw new AggregateException("All provided tasks failed to complete successfully.");
}

针对带返回值的Task<T>：

我们可以重载上面的方法，适配有返回值的任务：

public static async Task<Task<T>> WhenFirstSuccessful<T>(IEnumerable<Task<T>> tasks)
{
    var remainingTasks = tasks.ToList();
    while (remainingTasks.Count > 0)
    {
        var completedTask = await Task.WhenAny(remainingTasks);
        if (completedTask.Status == TaskStatus.RanToCompletion)
        {
            return completedTask;
        }
        remainingTasks.Remove(completedTask);
    }
    throw new AggregateException("All provided tasks failed to complete successfully.");
}

这种方法的优点是逻辑清晰，能明确处理“所有任务都失败”的场景，不会出现无限等待的情况。

方法二：用任务延续包装原任务 #

另一种思路是给每个原任务添加一个仅在成功时才完成的延续任务，然后对这些包装后的任务调用Task.WhenAny。这样，只有成功的任务对应的包装任务会被WhenAny选中。

public static Task<Task> WhenFirstSuccessfulAlternative(IEnumerable<Task> tasks)
{
    // 给每个任务添加延续：只有任务成功时，延续才会返回原任务
    var wrappedTasks = tasks.Select(task => 
        task.ContinueWith(t => t, TaskContinuationOptions.OnlyOnRanToCompletion));
    // 等待第一个包装任务完成，然后解包得到原任务
    return Task.WhenAny(wrappedTasks).Unwrap();
}

不过这种方法有个需要注意的点：如果所有原任务都失败了，那么所有包装后的任务都不会完成，Task.WhenAny会一直处于等待状态。所以如果用这种方法，建议额外搭配一个超时任务，避免无限等待：

public static async Task<Task> WhenFirstSuccessfulWithTimeout(IEnumerable<Task> tasks, TimeSpan timeout)
{
    var timeoutTask = Task.Delay(timeout);
    var wrappedTasks = tasks.Select(task => 
        task.ContinueWith(t => t, TaskContinuationOptions.OnlyOnRanToCompletion));
    // 把超时任务也加入等待列表
    var completedTask = await Task.WhenAny(wrappedTasks.Append(timeoutTask));
    if (completedTask == timeoutTask)
    {
        throw new TimeoutException("No task completed successfully within the timeout period.");
    }
    return ((Task<Task>)completedTask).Result;
}

使用示例 #

调用方法很简单，比如你有一批任务：

var tasks = new List<Task>
{
    Task.Factory.StartNew(() => { throw new Exception("Task 1 failed"); }),
    Task.Delay(2000), // 这个任务会成功完成
    Task.Factory.StartNew(() => { throw new Exception("Task 3 failed"); })
};

var firstSuccessful = await WhenFirstSuccessful(tasks);
Console.WriteLine($"First successful task status: {firstSuccessful.Status}");

这样就能拿到第一个成功完成的任务啦！

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