Najbardziej efektywny sposób przesyłania strumieniowego na liście kontraktów Futures

Question

Wywołuję metodę klienta asynchronicznego, przesyłając strumieniowo listę obiektów. Metoda zwraca Future.

Jaki jest najlepszy sposób na powtórzenie listy Futures zwróconych po zakończeniu połączenia (aby przetworzyć te Future, które są pierwsze)?

Uwaga: Klient asynchroniczny zwraca tylko wartość Future not CompletableFuture.

Poniżej znajduje się kod:

List<Future<Object>> listOfFuture = objectsToProcess.parallelStream() 
    .map((object) -> { 
     /* calling an async client returning a Future<Object> */ }) 
    .collect(Collectors.toList()); 

Answer 1

Mając tę ​​listę List<Future<Object>>, chciałbym złożyć go do puli niestandardowej, zamiast przy użyciu domyślnego przetwarzania strumienia równoległego.

Dzieje się tak dlatego, że api stream używa wspólnej puli do przetwarzania równoległego i zadzwonisz pod numer get w tych kontraktach Futures (jeśli proces ten zajmie dużo czasu) - zablokujesz wszystkie inne operacje strumieniowe, które wykorzystują operacje równoległe w aplikacji do momentu ten jest skończony.

To będzie trochę tak:

forJoinPool.submit(() -> list.stream().parallel().map(future -> future.get()).collect(Collectors.toList())).get(); 

pójdę z niestandardowym basenie jak pokazano here