-1

我正在使用 ContinueWith 链接任务并等待它们。当我在循环中引入延迟时(评论 - 这意味着有足够的时间完成任务),我可以看到所有任务都已完成。当我消除延迟时,我可以看到只处理了第一条消息。不处理剩余的消息。我假设代码在完成所有任务之前退出方法。不确定我是否在等待错误。

如何确保完成所有任务而不会在循环中引入延迟?

using (var throttler = new SemaphoreSlim(initialConcurrentJobsCount, maxConcurrentJobsCount))
{
     for(int counter = 0; counter < msgs.Length; counter++)
        {
            tasks[counter] = throttler.WaitAsync()
                                    .ContinueWith(r => new VirtualMachineActor().HandleAsync(msgs[counter]))
                                    .ContinueWith(o => throttler.Release());

                // When below line is present, all tasks are completed properly. 
                // When removed only first msg is executed.
                await Task.Delay(1000);  
       } 
       await Task.WhenAll(tasks);
}
4

1 回答 1

0

为了他人的利益,“ContinueWith”链并不一定意味着任务执行的顺序。它是一个包装器,因此需要“UnWrap”。

于 2017-02-15T04:09:41.533 回答