Comment garantir la fin des tâches lors de l'arrêt de Java ExecutorService

Arrêt de Java ExecutorService : garantir la fin des tâches

Lorsque vous utilisez Java ExecutorService, un aspect crucial est la gestion du processus d'arrêt pour garantir que toutes les tâches sont correctement terminées. Cela devient difficile lorsque des délais d'attente ou d'autres interruptions se produisent pendant l'exécution de la tâche.

Approche personnalisée

Le code fourni illustre un scénario dans lequel un ExecutorService, qui exécute des objets CallableTask, rencontre des difficultés s'arrêter une fois toutes les tâches terminées. Ce problème provient de la possibilité que les threads de tâches qui dépassent le seuil d'expiration restent actifs, empêchant ainsi l'arrêt de l'exécution.

Solution recommandée

Pour résoudre ce problème, l'API Oracle la documentation d'ExecutorService recommande l'approche suivante :

<code class="java">void shutdownAndAwaitTermination(ExecutorService pool) {
   pool.shutdown(); 
   try {
     if (!pool.awaitTermination(60, TimeUnit.SECONDS)) {
       pool.shutdownNow(); 
       if (!pool.awaitTermination(60, TimeUnit.SECONDS))
           System.err.println("Pool did not terminate");
     }
   } catch (InterruptedException ie) {
     pool.shutdownNow(); 
     Thread.currentThread().interrupt();
   }
}</code>

Cette méthode garantit un processus d'arrêt ordonné :

• shutdown() : désactive la soumission de nouvelles tâches.
• awaitTermination() : attend que le délai d'attente pour que les tâches existantes se terminent.
• shutdownNow() : interrompt l'exécution des tâches si waitTermination() échoue, en y mettant fin de force.

Bref résumé des méthodes liées à l'arrêt

• shutdown() : lance un arrêt ordonné où les tâches soumises sont exécutées, mais les nouvelles tâches sont rejetées.
• shutdownNow() : Tente d'arrêter toutes les tâches actives, d'arrêter les tâches en attente et de renvoyer une liste des tâches inachevées.
• awaitTermination() : bloque jusqu'à ce que toutes les tâches soient terminées (que ce soit par achèvement ou interruption).

Conseils supplémentaires

Pour prolonger le délai d'arrêt pour les tâches tenaces, modifiez waitTermination() :

<code class="java">if (!pool.awaitTermination(60, TimeUnit.SECONDS)) </code>

en :

<code class="java">while (!pool.awaitTermination(60, TimeUnit.SECONDS)) </code>

En mettant en œuvre ces techniques, vous pouvez améliorer la fiabilité de votre processus d'arrêt ExecutorService, garantissant ainsi la fin des tâches et le nettoyage du système.

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!