C#：等待所有线程完成
C#：等待所有线程完成
提问于 2008-11-04 19:35:37
在我正在编写的代码中，我遇到了一个常见的模式，在这种模式下，我需要等待一个组中的所有线程完成，并设置一个超时。timeout应该是所有线程完成所需的时间，所以简单地为每个线程执行thread.Join( timeout )将不起作用，因为可能的超时是timeout * numThreads。
现在，我做了类似以下的事情：
var threadFinishEvents = new List<EventWaitHandle>();
foreach (DataObject data in dataList)
{
// Create local variables for the thread delegate
var threadFinish = new EventWaitHandle(false, EventResetMode.ManualReset);
threadFinishEvents.Add(threadFinish);
var localData = (DataObject) data.Clone();
var thread = new Thread(
delegate()
{
DoThreadStuff(localData);
threadFinish.Set();
}
);
thread.Start();
}
Mutex.WaitAll(threadFinishEvents.ToArray(), timeout);然而，似乎应该有一个更简单的习语来描述这类事情。
回答 7
Stack Overflow用户
回答已采纳
发布于 2008-11-04 19:47:59
我仍然认为使用Join更简单。记录预期的完成时间(作为Now+timeout)，然后在循环中执行
if(!thread.Join(End-now))
throw new NotFinishedInTime();Stack Overflow用户
发布于 2011-06-17 08:15:04
在.NET 4.0中，我发现使用System.Threading.Tasks要容易得多。下面是spin-wait循环，它对我来说是可靠的。它会阻塞主线程，直到所有任务完成。也有Task.WaitAll，但这对我来说并不总是有效。
for (int i = 0; i < N; i++)
{
tasks[i] = Task.Factory.StartNew(() =>
{
DoThreadStuff(localData);
});
}
while (tasks.Any(t => !t.IsCompleted)) { } //spin waitStack Overflow用户
发布于 2010-10-11 09:01:09
因为这个问题被撞到了，所以我将继续并发布我的解决方案。
using (var finished = new CountdownEvent(1))
{
for (DataObject data in dataList)
{
finished.AddCount();
var localData = (DataObject)data.Clone();
var thread = new Thread(
delegate()
{
try
{
DoThreadStuff(localData);
threadFinish.Set();
}
finally
{
finished.Signal();
}
}
);
thread.Start();
}
finished.Signal();
finished.Wait(YOUR_TIMEOUT);
} 页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/263116
复制相关文章
相似问题