Comment procéder avec CompletableFuture sans attendre la sortie

Question

J'ai une situation où j'ai besoin d'implémenter une récursivité avec CompletableFuture. Je veux appeler recursionFuture(ex) chaque fois que l'un des CompletableFuture s renvoie n'importe quel résultat mais je ne suis pas sûr de savoir comment l'implémenter. Dans la situation actuelle, recursionFuture(ex) est appelée uniquement lorsque future1 et future2 renvoient la sortie, puis si la condition est vérifiée. Toute aide serait appréciée.

public static void recursionFuture(ExecutorService ex) 
    { 
     try 
     { 
      CompletableFuture<Object> future1 = CompletableFuture.supplyAsync(() -> new ConcurrencyPoC_CompletableFuture().executeTask(), ex); 
      CompletableFuture<Object> future2 = CompletableFuture.supplyAsync(() -> new ConcurrencyPoC_CompletableFuture().executeTask(), ex); 

      if (future1.get() != null | future2.get() != null) 
      { 
       System.out.println("Future1: " + future1.get() + " Future2: " + future2.get()); 
       recursionFuture(ex); 
      } 
     } 
     catch(Exception e) 
     { 
      e.printStackTrace(); 
     } 
    } 

Answer 1

Vous pouvez combiner avec anyOf()thenRun() pour y parvenir. Il suffit de ne pas appeler get() sur les deux contrats à terme, car cela fait attendre votre programme pour l'achèvement. Vous pouvez utiliser isDone() pour vérifier si un avenir est terminé avant d'appeler get().

CompletableFuture<Object> future1 = CompletableFuture.supplyAsync(() -> new ConcurrencyPoC_CompletableFuture().executeTask(), ex); 
CompletableFuture<Object> future2 = CompletableFuture.supplyAsync(() -> new ConcurrencyPoC_CompletableFuture().executeTask(), ex); 

CompletableFuture.anyOf(future1, future2).thenRun(() -> { 
    if (future1.isDone()) { 
     System.out.println("Future 1: " + future1.get()); 
    } 
    if (future2.isDone()) { 
     System.out.println("Future 2: " + future2.get()); 
    } 
    recursionFuture(ex); 
}); 

anyOf() va créer un nouvel avenir qui complétera dès que l'un des contrats à terme fournis a terminé. thenRun() exécutera le Runnable donné dès que le futur appelé est terminé.

Answer 2

Si vous utilisez uniquement deux CompletableFutures, vous pouvez également consulter runAfterEither/runAfterEitherAsync. Il existe également des versions qui permettent d'accéder à la valeur retournée comme acceptEither/acceptEitherAsync.