问题描述
我正在使用信号量将工作分散到固定数量的线程上,在完成所有工作之后,我希望继续进行所有结果。我目前正在等待信号量的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>
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)