单线程上的线程等待句柄

Question

我的代码是

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只能用于线程池，找不到单个线程使用的任何示例。我的应用程序需要很多线程，数百个线程，线程池有最大线程限制，其余任务排队等待。我该如何处理这些？更新：这是代码，请让我知道是否可能有更好的代码。

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);
    }
}

- Milan Solanki

---

但是你在这里实质上是在创建一个线程池。 - trutheality

Answer 1

在下面的例子中，我有三个需要跟踪的线程。当每个线程完成时，它会设置其相应的句柄。

像这样声明它：

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();

实际上，这有点简化了，但是如果你使waithandle静态，它将起作用。我实际上所做的是，在线程结束时让线程执行回调来发出waithandle信号。

在主线程中，可以像这样检查它。当waitcount达到零时，我知道所有线程都已经完成了。

while (waitcount > 0)
{
    WaitHandle.WaitAny(waithandles, 30000);
    waitcount--;
}

- edepperson

Answer 2

你可以使用 myThread.Join() 等待线程 myThread 完成。

- MRAB