我的代码是
public static void Invoke(Action[] Actions)
{
Thread[] threadArray = new Thread[Actions.Length];
for (int i = 0; i < Actions.Length; i++)
{
threadArray[i] = new Thread(() =>
{
Actions[i].Invoke();
});
threadArray[i].Start();
}
}
public static void WaitAll()
{
}
public static void WaitAny()
{
}
我想等待所有线程完成,并在任何线程完成时得到通知,
像 WaitAny
, WaitAll
但是 waithandles 只能在线程池上使用,找不到任何在单线程上使用的例子。
我的应用程序需要很多线程,数百个,adpool 有最大线程限制,其余任务排队。
我该如何管理?
更新:这是代码,如果有更好的代码,请告诉我。
public class ParallelV2
{
static int waitcount = 0;
static WaitHandle[] waitHandles;
public static void Invoke(Action[] Actions)
{
waitcount = Actions.Length;
Thread[] threadArray = new Thread[Actions.Length];
waitHandles = new WaitHandle[Actions.Length];
for (int i = 0; i < Actions.Length; i++)
{
var count = i;
waitHandles[count] = new AutoResetEvent(false);
threadArray[count] = new Thread(() =>
{
Actions[count].Invoke();
((AutoResetEvent)waitHandles[count]).Set();
});
threadArray[count].Start();
}
}
public static void WaitAll()
{
while (waitcount > 0)
{
WaitHandle.WaitAny(waitHandles);
waitcount--;
}
}
public static void WaitAny()
{
WaitHandle.WaitAny(waitHandles);
}
}
最佳答案
在下面的示例中,我需要跟踪三个线程。每个线程在完成后都会设置其相应的句柄。
声明如下:
private WaitHandle[] waithandles; // see comment on static below
像这样创建它:
waitcount = 3;
waithandles = new WaitHandle[3] { new AutoResetEvent(false), new AutoResetEvent(false), new AutoResetEvent(false) };
在线程中,当它结束时,这样设置:
((AutoResetEvent)waithandles[i]).Set();
(实际上,这过于简单了,但如果您将等待句柄设为静态,它就会起作用。我实际上所做的是让线程在其生命周期结束时执行回调以向等待句柄发出信号)
在主线程中,这样检查。当等待计数达到零时,我知道所有线程都已完成
while (waitcount > 0)
{
WaitHandle.WaitAny(waithandles, 30000);
waitcount--;
}
关于c# - 单个线程上的线程 WaitHandle,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/6741540/