我正在使用 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);
}