Task.WhenAll but Process 结果一一对应

Question

假设我有一个任务列表，我想并行运行它们。但我不需要所有这些都完成才能继续，我可以只用一个继续。以下代码等待所有任务完成继续。有没有办法让我在等待其他人完成的同时单独继续完成已完成的任务？

List<string>[] x = await Task.WhenAll(new Task<List<string>>[] { task1, task2 })
// when task1 finishes, I want to process the result immediately instead of waiting on task2.

提前致谢！

Answer 1

您可能正在寻找Task.WhenAny。

我用它来启动一堆任务，然后在它们准备好时处理它们，但我想你也可以等待一个任务完成，如果你不关心，也可以不循环继续处理其余的。

while(tasks.Count() > 0)
{
    var task = await Task.WhenAny(tasks);
    tasks.Remove(task);
    var taskresult = await task;
    // process result
}

Answer 2

您可以改用Task.WhenAny。

来自Stephen Cleary's Blog 的“被盗”示例：

var client = new HttpClient();
string results = await await Task.WhenAny(
    client.GetStringAsync("http://example.com"),
    client.GetStringAsync("http://microsoft.com"));
// results contains the HTML for whichever website responded first.

回复评论

您绝对可以跟踪其他任务：

// supposing you have a list of Tasks in `myTasks`:
while( myTasks.Count > 0 )
{
    var finishedTask = await Task.WhenAny(myTasks);
    myTasks.Remove(finishedTask);
    handleFinishedTask(finishedTask); // assuming this is a method that
                                      // does the work on finished tasks.
}

您唯一需要注意的是：

返回的任务将始终以 RanToCompletion 状态结束，其 Result 设置为第一个要完成的任务。 即使要完成的第一个任务以 Canceled 或 Faulted 状态结束也是如此。

Remarks in WhenAny Doks（我强调）

Answer 3

如果您使用的是 C# 8 和 .NET Core，则可以利用 IAsyncEnumerable 向消费方隐藏这种复杂性。

就像这样：

static async Task Main(string[] args)
{
    await foreach (var data in GetData())
    {
        Console.WriteLine(data);
    }

    Console.ReadLine();
}

static async IAsyncEnumerable<string> GetData()
{
    List<Task<string>> tasks = new List<Task<string>> {GetData1(), GetData3(), GetData2()};

    while (tasks.Any())
    {
        var finishedTask = await Task.WhenAny(tasks);
        tasks.Remove(finishedTask);
        yield return await finishedTask;
    }
}

static async Task<string> GetData1()
{
    await Task.Delay(5000);
    return "Data1";
}

static async Task<string> GetData2()
{
    await Task.Delay(3000);
    return "Data2";
}

static async Task<string> GetData3()
{
    await Task.Delay(2000);
    return "Data3";
}

Answer 4

如果您想按任务完成的顺序处理结果，可以使用 OrderByCompletion 扩展方法，该方法在 Stephen Cleary 的 Nito.AsyncEx 库中完全一样，签名如下：

// Creates a new collection of tasks that complete in order.
public static List<Task<T>> OrderByCompletion<T>(this IEnumerable<Task<T>> @this);

使用示例：

Task<string>[] tasks = new[] { task1, task2, task3, task4 };
foreach (var task in tasks.OrderByCompletion())
{
    string result = await task;
    // Do something with result
}

如果你不喜欢有外部依赖，源代码是here。