使用异步/等待多个任务

我正在使用完全异步的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请求，并在每个完成时写入控制台。

---

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将以并行方式异步执行您的操作。

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

---

我很好奇地看到问题中提供的方法的结果以及被接受的答案，所以我进行了测试。

代码如下：

class Program
{
    class Worker
    {
        public int Id { get; set; }
        public int SleepTimeout { get; set; }

        public async Task DoWork()
        {
            Console.WriteLine("Worker {0} started on thread {1} at {2}.",
                Id, Thread.CurrentThread.ManagedThreadId, DateTime.Now.ToString("hh:mm:ss.fff"));
            await Task.Run(() => Thread.Sleep(SleepTimeout));
            Console.WriteLine("Worker {0} stopped at {1}.",
                Id, DateTime.Now.ToString("hh:mm:ss.fff"));
        }
    }

    static void Main(string[] args)
    {
        var workers = new List<Worker>
        {
            new Worker { Id = 1, SleepTimeout = 3000 },
            new Worker { Id = 2, SleepTimeout = 3000 },
            new Worker { Id = 3, SleepTimeout = 3000 },
            new Worker { Id = 4, SleepTimeout = 3000 },
            new Worker { Id = 5, SleepTimeout = 3000 },
        };

        Console.WriteLine("Starting test: Parallel.ForEach");
        PerformTest_ParallelForEach(workers);
        Console.WriteLine("Test finished.n");

        Console.WriteLine("Starting test: Task.WaitAll");
        PerformTest_TaskWaitAll(workers);
        Console.WriteLine("Test finished.n");

        Console.WriteLine("Starting test: Task.WhenAll");
        var task = PerformTest_TaskWhenAll(workers);
        task.Wait();
        Console.WriteLine("Test finished.n");

        Console.ReadKey();
    }

    static void PerformTest_ParallelForEach(List<Worker> workers)
    {
        Parallel.ForEach(workers, worker => worker.DoWork().Wait());
    }

    static void PerformTest_TaskWaitAll(List<Worker> workers)
    {
        Task.WaitAll(workers.Select(worker => worker.DoWork()).ToArray());
    }

    static Task PerformTest_TaskWhenAll(List<Worker> workers)
    {
        return Task.WhenAll(workers.Select(worker => worker.DoWork()));
    }
}

结果输出：

---

由于您调用的API是异步的，因此Parallel.ForEach版本没有多大意义。 你不应该使用.Wait在WaitAll版本，因为那样会丧失并行的另一种选择，如果来电者是异步使用Task.WhenAll后做Select和ToArray生成任务的阵列。 第二种选择是使用Rx 2.0

链接地址: http://www.djcxy.com/p/82677.html

上一篇: Using async/await for multiple tasks

下一篇: HttpClient.GetAsync(...) never returns when using await/async