首页 > 解决方案 > 您如何正确等待所有信号量线程完成?

问题描述

我正在使用信号量将工作分散到固定数量的线程上,并且在完成所有工作之后,我想处理所有结果。我目前正在等到信号量的 CurrentCount 回到原来的限制,但是我很好奇是否有更好的方法来等到没有更多的工作/所有线程都恢复可用?

var semaphore = new SemaphoreSlim(5, 5);
foreach (var site in foundSites)
{
   await semaphore.WaitAsync();
   _ = Task.Run(async () =>
   {
      <PROCESSING CODE>
   }).ContinueWith(task => semaphore.Release());
}

while (semaphore.CurrentCount < 5)
{
   await Task.Delay(1);
}

<PROCESSING OF ALL PROCESSED ITEMS>

标签: c#multithreadingsemaphore

解决方案


推荐阅读