CompletableFuture allOf example 예제
IO가 오래걸리는 작업(db 또는 타 서비스 호출)에 CompletableFuture를 이용하면 쉽게 병렬 처리를 할 수 있습니다. 물론 db의 connection pool, 타 서비스 호출 시에 해당 서비스에서 감당할 수 있는 정도를 확인하고 상황에 맞게 동시 실행 Thread 개수를 지정합니다. List completableFutures = new ArrayList(); ExecutorService executorService = Executors.newFixedThreadPool(100); IntStream.rangeClosed(1, 100) .forEach(i -> { CompletableFuture completableFuture = CompletableFuture.supplyAsync(() -..
개발
2022. 6. 9. 17:59