如果foreach中的任务不是async,并使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.发布于 2015-04-25 13:00:00
不要使用任务的构造函数。它不支持异步lambda。相反,请使用Task.Run。
您的代码目前只等待任务中调用SendPingAsync,而不是等待整个异步方法完成。因为只要第一次等待点命中,异步方法就会返回。
异步lambda编译为Task(Action),这意味着它被编译为异步空方法。由于没有简单的方法等待异步空方法,任务类构造函数不支持它。相反,Task.Run通过过载支持异步方法。因为这会返回一个Task,所以Run方法可以很容易地等待它的完成。
不只是使用异步方法,总是更喜欢Task.Run或Task.Factory.StartNew(如果您需要更多的控制)。几乎没有理由使用Task构造函数。
如果您决定将StartNew用于异步方法,则必须调用Task.UnWrap并等待它返回的任务。当你使用Task.Run的时候,你可以免费得到它。
发布于 2015-04-25 12:59:03
如果您的匿名方法是异步的,则应该使用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方法一样)不受匿名方法本身返回需要等待的任务这一事实的影响;相反,它只是等待外部任务,一旦匿名方法结束,它就会完成。
另一方面,Task.Run有过载,可以通过打开它们并等待它们的内部任务来处理这些Func<Task>委托。因此,它将等待表示SendPingAsync调用完成的内部任务。
https://stackoverflow.com/questions/29865330
复制相似问题