Comment puis-je m'assurer que tous les threads sont terminés avant de continuer dans une application multithread Java ?

Coordonner l'exécution des threads en Java

Dans les applications multithread, il devient souvent nécessaire de synchroniser l'exécution des tâches sur plusieurs threads. Cela est particulièrement vrai lorsque le résultat de l'exécution d'un thread dépend de l'achèvement d'un autre. Dans ce contexte, explorons comment déterminer quand tous les threads d'un programme Java ont terminé leur travail.

Énoncé du problème :

Vous disposez d'une application avec cinq threads simultanément récupérer des données sur le Web et remplir cinq champs distincts dans une classe tampon partagée. Votre objectif est de valider les données du tampon et de les stocker dans une base de données une fois que tous les threads ont terminé leurs tâches. Le principal défi réside dans l'identification du moment où tous les threads ont fini de s'exécuter.

Solution :

Une approche efficace pour gérer les pools de threads consiste à utiliser un ExecutorService, qui fournit un moyen pratique de créer et de gérer des threads. Voici comment implémenter cette solution :

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.

Dans cet extrait de code, nous créons d'abord un ExecutorService à l'aide de la méthode Executors.newCachedThreadPool(). Cela crée un pool de threads qui ajuste dynamiquement sa taille en fonction du nombre de tâches soumises. Nous soumettons ensuite cinq tâches au service exécuteur à l'aide de la méthode execute().

Une fois toutes les tâches soumises, nous appelons la méthode shutdown() pour indiquer qu'aucune autre tâche ne sera soumise au service exécuteur. Après cela, nous invoquons la méthode waitTermination() avec un délai d'attente spécifié (1 minute dans ce cas). Cette méthode bloque le thread en cours jusqu'à ce que toutes les tâches soient terminées ou que le délai d'attente soit atteint.

La variable terminée sera définie sur true si toutes les tâches sont terminées avant le délai d'attente, et sur false sinon. Vous pouvez ensuite effectuer les opérations de validation et de stockage de base de données nécessaires en fonction de la valeur de finish.

En utilisant ExecutorService et la méthode waitTermination(), vous pouvez effectivement attendre que tous les threads de votre programme Java aient terminé leur travail. puis passez aux étapes suivantes de votre candidature.

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!