Warten auf einige Frühling ListenableFuture

Question

Es gibt einen Dienst, der Spring AsyncRestTemplate zum Senden von Ruheaufrufen verwendet. Jeder Anruf von AsyncRestTemplate.exchange() gibt ListenableFuture zurück. Etwas wie folgt aus:

ListenableFuture future1 = new AsyncRestTemplate().exchange(...); 
    ListenableFuture future2 = new AsyncRestTemplate().exchange(...); 
    ListenableFuture future3 = new AsyncRestTemplate().exchange(...); 

Gibt es eine Möglichkeit für einzelne ListenableFuture zu schaffen, die alle anderen Anrufe kombiniert? Etwas wie Futures.allAsList von Guava.

Answer 1

Schritt # 1: jeder ListenableFuture konvertieren

CompletableFuture

public CompletableFuture<T> toCompletableFuture(ListenableFuture<ResponseEntity<String>> listenableFuture) { 
    final CompletableFuture<T> completableFuture = new CompletableFuture<>(); 

    listenableFuture.addCallback(new ListenableFutureCallback<ResponseEntity<String>>() { 
     @Override 
     public void onFailure(Throwable e) { 
      completableFuture.completeExceptionally(e); 
      } 
     } 

     @Override 
     public void onSuccess(ResponseEntity<String> result) { 
      completableFuture.complete(parseResponse(result)); 
      } 
     } 
    }); 
    return completableFuture; 
} 

Schritt # 2: CompletableFuture.allOf (CF1, CF2, cF3 ...)