Java执行多个线程并等待完成[重复]

Question

我正在编写一个小程序，它应该更新服务器上的固件。我目前这样做的方式是通过 ProcessBuilder 发出命令，执行它并使用exitCode = process.waitFor(); 等待命令完成。

其中一些固件更新可能需要几分钟，因此在设置多个系统时，如果单独进行这些固件更新可能需要数小时。

我尝试在使用 CyclicBarrier 时创建线程，以确保同时启动所有固件更新。 （见：Stackoverflow-Question: How to start two threads at “exactly” the same time

然而，我发现的问题是，在启动所有线程后，我的程序将照常继续 - 在这种情况下，将重新启动所有系统，如果它们仍在更新过程中，这可能会破坏它们固件。

如何确保在继续之前完成所有固件更新？我曾想过让程序休眠 10-15 分钟，但想要一种更可靠的方法。

Answer 1

除了屏障之外，您还可以使用CountDownLatch。将CountDownLatch 传递给每个线程，一旦固件更新完成，只需调用闩锁上的倒计时。在您的主线程中，启动所有线程后，您可以通过调用latch.await 等待，它会一直等待，直到所有其他线程完成。您可以找到一个示例here。

您甚至可以使用 CountDownLatch 和 1 作为发令枪的计数，这样就无法使用 CyclicBarrier。

Answer 2

您需要Thread.join() 方法。看例子：

public static void main(String[] args) throws InterruptedException {
        Runnable sleepTwoSeconds = () -> {
            try {
                Thread.sleep(2000);
                System.out.println("Sleeping finished");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        };
        Thread t1 = new Thread(sleepTwoSeconds);
        t1.start();
        Thread t2 = new Thread(sleepTwoSeconds);
        t2.start();
        t1.join();
        t2.join();
        System.out.println("Main thread continue.");

    }

“如何确保在继续之前完成所有固件更新？”在 t1 和 t2 完成之前，主线程不会继续。