当所有线程完成时

Question

这是我第一次真正尝试使用多线程，我想知道如何判断我的所有任务组何时完成运行：

for (int i = 0; i < taskGroups.Count(); i++) {
    ThreadStart t = delegate { RunThread(taskGroups[i]); };
    new Thread(t).Start();
}
if(allThreadsComplete){ //???

}

任何帮助将不胜感激

附录：

ThreadStart[] threads = new ThreadStart[taskGroups.Count()];
for (int i = 0; i < taskGroups.Count(); i++) {
    threads[i] = new ThreadStart[]
    threads[i] = delegate { RunThread(taskGroups[i]); };
    new Thread(t).Start();
}
bool threadsComplete = false;
while(!threadsComplete){
    for(int i=0;i<taskGroups.Count();i++){
        if(threads[i].State == complete)
        threadsComplete = true;
    }
}

Answer 1

您需要存储所有线程，然后调用 Thread.Join()。

像这样的事情：

List<Thread> threads = new List<Thread>();
for (int i = 0; i < taskGroups.Count(); i++) {
   int temp = i; //This fixes the issue with i being shared
   Thread thread = new Thread(() => RunThread(taskGroups[temp]));
   threads.Add(thread);
   thread.Start();
}

foreach (var thread in threads) {
    thread.Join();
}

Answer 2

如果您使用的是 3.5，那么您可以编写自己的 CountdownEvent，如果您使用的是 4.0，那么您可以使用内置的 CountdownEvent 执行如下操作：

CountdownEvent = new CountdownEvent(taskGroups.Count());

for (int i = 0; i < taskGroups.Count(); i++) 
{
    int item = i; // copy i locally
    ThreadStart t = delegate 
    { 
        RunThread(taskGroups[item]); 
        latch.Signal();
    };
    new Thread(t).Start();
}

latch.Wait();

latch.Wait() 将导致您的代码阻塞，直到线程全部完成。此外，您可能想稍微改变一下启动线程的方式：

CountdownEvent = new CountdownEvent(taskGroups.Count());

for (int i = 0; i < taskGroups.Count(); i++) 
{
    int item = i; // copy i locally
    Thread t = new Thread(()=>
    { 
        RunThread(taskGroups[item]); 
        latch.Signal();
    });
    t.IsBackground = true;
    t.Start();
}

latch.Wait();

请注意，我将线程设置为后台：这样您的应用程序在退出时不会挂起，并且并非所有线程都已完成（即防止幽灵或守护线程）。

Answer 3

您可以使用 Thread.Join 确保每个单独的线程都已完成跑步。

Answer 4

您可以将公共静态整数字段添加到主线程，在每个子线程中，完成后将其加一，然后在主线程中等待（循环），直到该变量等于taskGroups.Count()< /代码>。

Answer 5

首先考虑使用 任务。

无论如何，如果您想等待所有线程，您可以调用 Thread.Join：

var threads = new List<Thread>();    
for (int i = 0; i < taskGroups.Count(); i++) {
    ThreadStart t = delegate { RunThread(taskGroups[i]); };
    var thread = new Thread(t);
    threads.Add(thread);
    thread.Start();
}

threads.ForEach(a => a.Join());

请记住，您还可以传递一个超时参数，该参数仅在线程完成时间不超过指定时间时才会等待。你进来的时间。

Answer 6

您可以检查每个 Thread 对象的 ThreadState 属性。