在我正在编写的代码中,我遇到了一个常见的模式,在这种模式下,我需要等待一个组中的所有线程完成,并设置一个超时。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);
然而,似乎应该有一个更简单的习语来描述这类事情。
发布于 2008-11-04 19:47:59
我仍然认为使用Join更简单。记录预期的完成时间(作为Now+timeout),然后在循环中执行
if(!thread.Join(End-now))
throw new NotFinishedInTime();
发布于 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 wait
发布于 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);
}
https://stackoverflow.com/questions/263116
复制相似问题