c# - 单个线程上的线程 WaitHandle

标签 c# .net windows multithreading parallel-processing

我的代码是

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/

相关文章:

c# - 在调用 Read() 之前访问字段的尝试无效

windows - LDAP 与 Windows AD 的绑定(bind)失败并显示 80090308 : LdapErr: DSID-0C0903AA

c# - 如何使用 linq 从 Excel 中检索数据?

c# - 如何使用 ASP.NET MVC 5 访问 Facebook 个人资料信息

c# - System.Random 会始终为跨平台的给定种子生成可预测的数字吗?

c# - 在 Linux 上查看 dotnetcore 2 自包含应用程序的内存使用情况统计信息

.net - .NET 上服务层的扩展策略

c# - SystemEvents.SessionSwitch 哪个用户被锁定/解锁

c# - 您如何检测文件何时被放入 Windows 资源管理器?

windows - 从 .bat 脚本运行 Powershell 命令不起作用,但是当我直接在命令行中键入它时它起作用