如何确保所有 Java 线程在继续之前完成？

如何在 Java 中等待所有线程完成其工作

使用多个线程时，协调它们的执行并确保它们在继续之前完成任务至关重要。在此场景中，您有五个线程同时从 Web 获取数据并填充缓冲区类。您的目标是验证缓冲区中的数据，并仅在所有线程完成其工作时将其存储在数据库中。

ExecutorService 解决方案

在 Java 中实现此目的的一种有效方法是通过利用 ExecutorService，它提供了一个方便的 API 来管理线程池。以下是实现此方法的方法：

ExecutorService es = Executors.newCachedThreadPool();

// Submit the tasks to the executor service
for (int i = 0; i < 5; i++) {
    es.execute(new Runnable() {
        // Implement your task here
    });
}

// Shut down the executor service after submitting the tasks
es.shutdown();

// Wait for all tasks to finish or for a specified timeout
boolean finished = es.awaitTermination(1, TimeUnit.MINUTES);

// If all tasks have finished, proceed with validation and database storage
if (finished) {
    validateBufferData();
    storeDataInDatabase();
}

通过使用awaitTermination方法，您可以阻塞主线程，直到执行程序服务中的所有任务完成或达到指定的超时。这确保了数据验证和数据库存储仅在所有线程完成其工作时发生。

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