How to Ensure All Java Threads Finish Before Proceeding?

How to Wait for All Threads to Complete Their Work in Java

When working with multiple threads, coordinating their execution and ensuring they complete their tasks before proceeding is essential. In this scenario, you have five threads that are concurrently fetching data from the web and populating a buffer class. Your goal is to validate the data in the buffer and store it in a database only when all threads have finished their work.

Solution باستخدام ExecutorService

One effective way to achieve this in Java is by leveraging the ExecutorService, which provides a convenient API for managing thread pools. Here's how you can implement this approach:

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();
}

By utilizing the awaitTermination method, you can block the main thread until all tasks in the executor service have completed or until the specified timeout has been reached. This ensures that data validation and database storage only occur when all threads have finished their work.

The above is the detailed content of How to Ensure All Java Threads Finish Before Proceeding?. For more information, please follow other related articles on the PHP Chinese website!