Executor 프레임워크와 CompletableFuture는 비동기 작업에 어떻게 도움이 됩니까?

Question

Accepted Answer

**Executor 프레임워크**는 thread 풀을 관리하여 수동으로 thread를 생성하는 대신 *작업*을 제출하게 하고, **`CompletableFuture`**는 비동기 연산을 선언적으로 조합합니다. 이들이 함께 Java에서 동시/비동기 작업을 하는 현대적 방법입니다 — 원시 thread 관리의 비용과 복잡성을 피합니다. ## 원시 thread 의 문제 ```java // ❌ 작업마다 thread 를 생성하는 것은 비싸고 무한정 → 리소스를 고갈시킬 수 있음 for (Task t : tasks) { new Thread(() -> process(t)).start(); // 10,000개 작업 → 10,000개 thread → 크래시 } ``` ## ExecutorService — 관리되는 thread 풀 ```java // ✅ 고정 풀은 제한된 thread 집합을 여러 작업에 재사용 ExecutorService executor = Executors.newFixedThreadPool(10); Future future = executor.submit(() -> compute()); // 작업 제출 Integer result = future.get(); // 결과가 준비될 때까지 블로킹 executor.shutdown(); // 작업 수락 중단; 실행 중인 것은 끝내게 함 ``` `ExecutorService`는 *무엇*(작업)을 *어떻게*(thread 관리)에서 분리합니다 — 제한된 thread 풀을 재사용하여 리소스 고갈과 끊임없는 thread 생성의 오버헤드를 방지합니다. ## Future 의 한계 ```java Future f = executor.submit(task); f.get(); // ❌ 호출 thread 를 블로킹; 블로킹 없이 체이닝/결합 불가 ``` `Future.get()`은 블로킹하며, 종속 연산을 쉽게 체이닝하거나 결과를 결합할 수 없습니다 — 이것이 `CompletableFuture`가 해결하는 것입니다. ## CompletableFuture — 조합 가능한 비동기 ```java CompletableFuture.supplyAsync(() -> fetchUser(id)) // 비동기 실행, 값 반환 .thenApply(user -> user.getName()) // 결과 변환 (논블로킹) .thenApply(String::toUpperCase) .thenAccept(name -> System.out.println(name)) // 최종 결과 소비 .exceptionally(ex -> { log(ex); return null; }); // 체인의 오류 처리 ``` `CompletableFuture`는 **논블로킹 파이프라인**을 구축하게 합니다 — 변환(`thenApply`), 종속 비동기 호출 체이닝(`thenCompose`), 오류 처리(`exceptionally`) — thread를 블로킹하지 않고. ## 여러 비동기 연산 결합 ```java // 독립적인 두 비동기 호출을 병렬로 실행하고 결과를 결합 CompletableFuture userF = CompletableFuture.supplyAsync(() -> fetchUser(id)); CompletableFuture orderF = CompletableFuture.supplyAsync(() -> fetchOrder(id)); userF.thenCombine(orderF, (user, order) -> buildProfile(user, order)) .thenAccept(profile -> render(profile)); // 여러 개가 완료되기를 기다림 CompletableFuture.allOf(f1, f2, f3).join(); // 모두 완료 ``` `thenCombine`, `allOf`, `anyOf`는 여러 비동기 작업을 우아하게 조율합니다 — 독립적인 작업을 병렬로 실행하고 결과를 결합합니다. ## 왜 중요한가 Executor 프레임워크와 CompletableFuture는 Java에서 동시성과 비동기 작업을 다루는 **현대적이고 올바른 방법**으로, 오류가 발생하기 쉬운 수동 thread 관리를 대체합니다. thread 풀(ExecutorService)은 작업마다 thread를 생성하는 리소스 고갈과 오버헤드를 피합니다 — 확장 가능한 서버에 필수적입니다. CompletableFuture는 Future의 블로킹 한계를 해결하여, 비동기 연산을 체이닝, 변환, 결합, 오류 처리하는 **조합 가능한 논블로킹 파이프라인**을 선언적으로 가능하게 합니다 — 많은 동시 호출(데이터베이스, API, 마이크로서비스)을 조율해야 하는 효율적인 I/O 바운드 서비스에 결정적입니다. 이들을 (원시 thread와 블로킹 Future 대신) 이해하는 것은 성능 좋고 확장 가능한 동시 Java 애플리케이션을 구축하는 데 근본적이며 핵심적인 시니어 수준 역량입니다.