Comment s'assurer que tous les threads Java sont terminés avant de continuer ?

Comment attendre que tous les threads terminent leur travail en Java

Lorsque vous travaillez avec plusieurs threads, il est essentiel de coordonner leur exécution et de s'assurer qu'ils terminent leurs tâches avant de continuer. Dans ce scénario, vous disposez de cinq threads qui récupèrent simultanément des données sur le Web et remplissent une classe tampon. Votre objectif est de valider les données dans le tampon et de les stocker dans une base de données uniquement lorsque tous les threads ont terminé leur travail.

Solution باستخدام ExecutorService

Un moyen efficace d'y parvenir en Java consiste à en tirant parti d'ExecutorService, qui fournit une API pratique pour gérer les pools de threads. Voici comment implémenter cette approche :

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

En utilisant la méthode waitTermination, vous pouvez bloquer le thread principal jusqu'à ce que toutes les tâches du service exécuteur soient terminées ou jusqu'à ce que le délai d'attente spécifié soit atteint. Cela garantit que la validation des données et le stockage de la base de données n'ont lieu que lorsque tous les threads ont terminé leur travail.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!