在 Java 多线程应用程序中，如何确保所有线程在继续之前完成？

在 Java 中协调线程执行

在多线程应用程序中，通常需要同步多个线程之间的任务完成。当一个线程的执行结果取决于另一个线程的完成时尤其如此。在这种情况下，让我们探讨如何确定 Java 程序中的所有线程何时完成其工作。

问题陈述：

您有一个同时具有五个线程的应用程序从网络检索数据并填充共享缓冲区类中的五个不同字段。您的目标是在所有线程完成其任务后验证缓冲区数据并将其存储在数据库中。关键的挑战在于确定所有线程完成执行的时刻。

解决方案：

管理线程池的一种有效方法是使用 ExecutorService，它提供了一种创建和管理线程的便捷方法。以下是实现此解决方案的方法：

ExecutorService es = Executors.newCachedThreadPool();
for (int i = 0; i < 5; i++) {
    es.execute(new Runnable() { /* Implement your task */ });
}
es.shutdown();
boolean finished = es.awaitTermination(1, TimeUnit.MINUTES);
// All tasks have finished or the time has been reached.

在此代码片段中，我们首先使用 Executors.newCachedThreadPool() 方法创建一个 ExecutorService。这将创建一个线程池，该线程池根据提交的任务数量动态调整其大小。然后，我们使用execute()方法向执行器服务提交五个任务。

提交所有任务后，我们调用shutdown()方法来指示不再向执行器服务提交任何任务。之后，我们以指定的超时（本例中为 1 分钟）调用awaitTermination() 方法。此方法会阻塞当前线程，直到所有任务完成或达到超时。

如果所有任务在超时之前完成，则 finish 变量将设置为 true，否则设置为 false。然后，您可以根据finished的值执行必要的验证和数据库存储操作。

通过利用ExecutorService和awaitTermination()方法，您可以有效地等待，直到Java程序中的所有线程完成其工作然后继续您的应用程序中的后续步骤。

以上是在 Java 多线程应用程序中，如何确保所有线程在继续之前完成？的详细内容。更多信息请关注PHP中文网其他相关文章！