为什么 Task.WhenAll(taskList) 不起作用？

Question

如果 foreach 中的任务不是 async，则将 ping.Send 改为 ping.Send ping.SendPingAsync 然后 Task.WhenAll(taskList) 就可以了。

List<Task> taskList = new List<Task>();   

foreach (var host in hostArray)
{
    var aHost = host;
    Task task = new Task(async ()=>        
    {
        Ping ping = new Ping();
        PingResult pingRes = new PingResult { HostNameOrAddress = aHost };
        for (int i = 0; i < _pingCount; i++)
        {
            try
            {
                PingReply reply = await ping.SendPingAsync(aHost,1000);
                if (reply.Status == IPStatus.Success)
                    pingRes.RoundtripTimes.Add(reply.RoundtripTime);
            }
            catch
            {
                // ignored
            }
        }

        Dispatcher.Invoke(() =>
        {
            _pingResultList.Add(pingRes);                                
        });
    });

    taskList.Add(task);
    task.Start();
}

await Task.WhenAll(taskList); //Never wait.

Answer 1

当您的匿名方法是异步的时，您应该使用 Task.Run 方法而不是 Task 构造函数。

foreach (var host in hostArray)
{
    Task task = Task.Run(async () =>
    {
        // ...
    });

    taskList.Add(task);
}

await Task.WhenAll(taskList);

C# 编译器将异步方法转换为 Func<Task> 委托。因此，当你运行他们通过一个任务时，外部任务实际上是一个 Task<Task> – 即一个任务在执行时生成另一个任务。

Task 构造函数（如 Task.Factory.StartNew 方法）不受以下事实影响：您的匿名方法本身 returns 一个任务需要等待；相反，它只是等待外部任务，该任务会在您的匿名方法结束时立即完成。

另一方面，

Task.Run 具有可以通过展开并等待其内部任务来处理此类 Func<Task> 委托的重载。因此，它将等待表示 SendPingAsync 调用完成的内部任务。

Answer 2

不要使用任务的构造函数。它不支持异步 lambda。而是使用 Task.Run.

你的代码目前只等到你的 SendPingAsync 在你的任务中被调用，而不是等待整个异步方法完成。因为一旦第一个等待点命中，异步方法 return.

您的异步 lambda 编译为 Task(Action)，这意味着它被编译为 async void 方法。由于没有简单的方法来等待 async void 方法，因此 Task class 构造函数不支持它。相反 Task.Run 通过 Task.Run(Func<Task>) overload 支持异步方法。由于此 return 是一个 Task，运行方法可以轻松等待其完成。

不仅使用异步方法，总是更喜欢 Task.Run 或 Task.Factory.StartNew（如果您需要更多控制）。几乎没有理由使用 Task 构造函数。

如果您决定对异步方法使用 StartNew，则必须调用 Task.UnWrap 并等待由它执行的任务 return。当您使用 Task.Run 时，您可以免费获得它。

为什么 Task.WhenAll(taskList) 不起作用？

Why Task.WhenAll(taskList) doesn't work?

c#

asynchronous

task

async-await