首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >为什么Task.WhenAll(taskList)不能工作?

为什么Task.WhenAll(taskList)不能工作?
EN

Stack Overflow用户
提问于 2015-04-25 12:45:06
回答 2查看 4.3K关注 0票数 2

如果foreach中的任务不是async,并使ping.Send代替ping.SendPingAsync,那么Task.WhenAll(taskList)就能工作。

代码语言:javascript
复制
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.
EN

回答 2

Stack Overflow用户

回答已采纳

发布于 2015-04-25 13:00:00

不要使用任务的构造函数。它不支持异步lambda。相反,请使用Task.Run

您的代码目前只等待任务中调用SendPingAsync,而不是等待整个异步方法完成。因为只要第一次等待点命中,异步方法就会返回。

异步lambda编译为Task(Action),这意味着它被编译为异步空方法。由于没有简单的方法等待异步空方法,任务类构造函数不支持它。相反,Task.Run通过过载支持异步方法。因为这会返回一个Task,所以Run方法可以很容易地等待它的完成。

不只是使用异步方法,总是更喜欢Task.RunTask.Factory.StartNew(如果您需要更多的控制)。几乎没有理由使用Task构造函数。

如果您决定将StartNew用于异步方法,则必须调用Task.UnWrap并等待它返回的任务。当你使用Task.Run的时候,你可以免费得到它。

票数 9
EN

Stack Overflow用户

发布于 2015-04-25 12:59:03

如果您的匿名方法是异步的,则应该使用Task.Run方法而不是Task构造函数。

代码语言:javascript
复制
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方法一样)不受匿名方法本身返回需要等待的任务这一事实的影响;相反,它只是等待外部任务,一旦匿名方法结束,它就会完成。

另一方面,Task.Run有过载,可以通过打开它们并等待它们的内部任务来处理这些Func<Task>委托。因此,它将等待表示SendPingAsync调用完成的内部任务。

票数 6
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/29865330

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档