Comment puis-je gérer efficacement les erreurs et la résiliation anticipée lorsque je travaille avec Futures ?

Attente de résiliation anticipée pour une liste de futurs

Lorsque vous traitez des tâches asynchrones représentées par des futurs, il est souvent crucial d'attendre que tous les traitements soient terminés. terminé ou une erreur se produit. Cependant, il n'est pas souhaitable d'attendre inutilement que toutes les tâches soient terminées, même après qu'une erreur s'est produite.

Pour résoudre ce problème, envisagez les étapes suivantes :

1. Utiliser un CompletionService :

   • Créez un CompletionService pour recevoir les contrats à terme dès qu'ils deviennent disponibles.
   • Soumettez des tâches à l'aide d'objets appelables qui encapsulent le traitement.

2. Surveiller les contrats à terme de manière séquentielle :

   • Utilisez une boucle pour parcourir les contrats à terme reçus du CompletionService.
   • Tenter de récupérer le résultat de chaque futur en utilisant Future.get().
   • Si un futur génère une exception, définissez un indicateur pour indiquer qu'une erreur s'est produite.

3. Annuler Tâches restantes :

   • Une fois qu'une erreur a été détectée, annulez toutes les tâches restantes pour éviter une attente inutile.

Voici un exemple qui démontre cette approche :

<code class="java">Executor executor = Executors.newFixedThreadPool(4);
CompletionService<SomeResult> completionService = 
       new ExecutorCompletionService<SomeResult>(executor);

// 4 tasks
for(int i = 0; i < 4; i++) {
   completionService.submit(new Callable<SomeResult>() {
       public SomeResult call() {
           // Processing code
           return result;
       }
   });
}

int received = 0;
boolean errors = false;

while(received < 4 && !errors) {
      Future<SomeResult> resultFuture = completionService.take(); // Blocks until available
      try {
         SomeResult result = resultFuture.get();
         received ++;
         // Process the result
      }
      catch(Exception e) {
         // Log or handle the error
         errors = true;
      }

      if (errors) {
         // Cancel any remaining tasks
         executor.shutdown();
         break;
      }
}</code>

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!