对多个任务使用异步/等待

一尘不染

对多个任务使用异步/等待

我使用的是完全异步的API客户端，也就是说，每个操作要么返回Task要么Task<T>，例如：

static async Task DoSomething(int siteId, int postId, IBlogClient client)
{
    await client.DeletePost(siteId, postId); // call API client
    Console.WriteLine("Deleted post {0}.", siteId);
}

使用C＃5 async / await运算符，启动多个任务并等待所有任务完成的正确/最有效方法是什么：

int[] ids = new[] { 1, 2, 3, 4, 5 };
Parallel.ForEach(ids, i => DoSomething(1, i, blogClient).Wait());

要么：

int[] ids = new[] { 1, 2, 3, 4, 5 };
Task.WaitAll(ids.Select(i => DoSomething(1, i, blogClient)).ToArray());

由于API客户端在内部使用HttpClient，因此我希望它可以立即发出5个HTTP请求，并在每个请求完成时写入控制台。

阅读 248

2020-05-19

共1个答案

一尘不染

int[] ids = new[] { 1, 2, 3, 4, 5 };
Parallel.ForEach(ids, i => DoSomething(1, i, blogClient).Wait());

尽管您与上述代码并行运行这些操作，但是此代码阻止了每个操作在其上运行的每个线程。例如，如果网络调用花费2秒钟，则每个线程在不执行任何操作（除了等待）的情况下将挂起2秒钟。

int[] ids = new[] { 1, 2, 3, 4, 5 };
Task.WaitAll(ids.Select(i => DoSomething(1, i, blogClient)).ToArray());

另一方面，上面的代码WaitAll还会阻塞线程，并且在操作结束之前，线程将无法自由处理任何其他工作。

推荐方法

我希望WhenAll它将在Parallel中异步执行您的操作。

public async Task DoWork() {

    int[] ids = new[] { 1, 2, 3, 4, 5 };
    await Task.WhenAll(ids.Select(i => DoSomething(1, i, blogClient)));
}

实际上，在上述情况下，您甚至不需要await，您可以直接从方法返回，因为您没有任何延续：
public Task DoWork()
{
    int[] ids = new[] { 1, 2, 3, 4, 5 };
    return Task.WhenAll(ids.Select(i => DoSomething(1, i, blogClient)));
}

作为支持，这是一篇详细的博客文章，介绍了所有其他选择以及它们的优点/缺点：如何以及在何处使用ASP.NET Web API进行并发异步I /
O

2020-05-19