单线程上的线程WaitHandle
单线程上的线程WaitHandle
提问于 2011-07-19 02:07:33
我的代码是
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
但是，只能在线程池上使用腰围，无法在单个线程上找到使用的任何示例。
我的应用程序需要很多线程，其中数百个线程，线程池有最大线程限制，rest任务排队。
我该怎么做？？
更新：这里是代码，请告诉我是否可能有更好的代码。
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);
}
}回答 2
Stack Overflow用户
回答已采纳
发布于 2011-07-19 02:50:14
在下面的示例中，我需要跟踪三个线程。完成时，每个线程都会设置相应的句柄。
声明如下：
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--;
}Stack Overflow用户
发布于 2011-07-19 02:22:31
您可以等待线程myThread与myThread.Join()一起完成。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/6741540
复制相关文章
相似问题
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号