多线程 - 在创建新线程之前等待子线程 - Java

Question

我正在创建“大线程”，让我们将它们命名为 A、B、C... 并将它们放入队列中。 这些“大线程”中的每一个都在其中创建子线程。 a1, a2, a3, b1, b2, b3, c1, c2, c3...

我所做的是检查 A 是否已终止，然后启动 B 等等。但是当A完成时，a1、a2、a3同时启动和运行，A变成TERMINATED。所以 B 紧随其后的是 b1、b2、b3。我不希望这种情况发生。如何检查或让 A 等待 a1、a2、b3 然后被终止？

我已经对代码进行了简化和匿名化，但基本思想是一样的：

这里是创建可运行 foo 类并将其添加到队列中的地方，仅供参考：

RunnableFooClass rc = new RunnableFooClass();
Thread t = new Thread(rc);

这是在可运行的 foo 类（“大线程”）中创建的可运行 bar 类（“子线程”）的运行方法

@Override
public void run() {
    for(int i=0; i<Constants.THREAD_NUM; i++){
         //initialize t
         t.start
    }
}

以下代码处于无限循环中：

if(jobQueue.peek().getState() == Thread.State.TERMINATED){
    try {
        jobQueue.peek().join();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    System.out.println(jobQueue.poll().getName() + "end.");
}
if(jobQueue.peek() != null){
    jobQueue.peek().start();
    System.out.println(jobQueue.peek().getName() + "start.");
}

Answer 1

基本解决方案是使用CountDownLatch。

在线程 A 中创建一个初始化为 THREAD_NUM 的锁存器并将其传递给每个子线程：

@Override
public void run() {
    CountDownLatch latchA = new CountDownLatch(Constants.THREAD_NUM);
    for(int i=0; i<Constants.THREAD_NUM; i++){
         RunnableFooClass rc = new RunnableFooClass(latchA);
         Thread t = new Thread(rc);
         t.start();
    }
    latchA.await(); // wait for termination of all subthreads
}

然后，在子线程的最后run()

latchA.countDown();