Javahard

CompletableFuture — do czego służy i jaka jest typowa pułapka?

Tagi

#completablefuture#async#concurrency

Odpowiedź

To reprezentacja asynchronicznego obliczenia, które możesz składać (`thenApply/thenCompose`) bez blokowania. Typowa pułapka to zbyt wczesne `get()/join()` (zamiana na kod blokujący) albo brak obsługi wyjątków (`exceptionally/handle`).

CompletableFuture<Integer> result = CompletableFuture
  .supplyAsync(() -> 40)
  .thenApply(x -> x + 2)
  .exceptionally(e -> 0);

System.out.println(result.join());

Odpowiedź zaawansowana

Głębiej

`CompletableFuture` pozwala budować asynchroniczny pipeline:

Transformacja: `thenApply`
Składanie async etapów: `thenCompose`
Łączenie: `thenCombine`, `allOf`, `anyOf`
Obsługa błędów: `exceptionally`, `handle`

Typowe pułapki

Zbyt wczesne blokowanie `join()`/`get()` (tracisz korzyści async).
Użycie common ForkJoinPool do blokującego IO (ryzyko zagłodzenia wątków). Daj dedykowany `Executor`.
Mylenie `thenApply` z `thenCompose` (zagnieżdżone future).

Przykład

CompletableFuture<User> f = CompletableFuture.supplyAsync(this::loadUser, ioPool)
  .thenCompose(user -> CompletableFuture.supplyAsync(() -> loadProfile(user), ioPool))
  .exceptionally(ex -> fallbackUser());