CompletableFuture1

자바에서 비동기(Asynchronous) 프로그래밍을 가능케하는 인터페이스

• Future를 사용해서도 어느정도 가능했지만 하기 힘들 일들이 많았다.

Futrue로는 하기 어렵던 작업들

• Future를 외부에서 완료 시킬 수 없다. 취소하거나, get()에 타임아웃을 설정할 수는 있다.
• 블로킹 코드(get())를 사용하지 않고서는 작업이 끝났을 때 콜백을 실행할 수 없다.
• 여러 Future를 조합할 수 없다. 예) Event 정보 가져온 다음 Event에 참석하는 회원 목록 가져오기
• 예외 처리용 API를 제공하지 않는다.

CompletableFuture

• Implements Future
• Implements CompletionStage

비동기로 작업 실행하기

• 리턴값이 없는 경우: runAsync()
• 리턴값이 있는 경우: supplyAsync()
• 원하는 Executor(쓰레드풀)를 사용해서 실행할 수도 있다.(기본은 ForkJoinPool.commonPool())

콜백 제공하기

• thenApply(Function): 리턴값을 받아서 다른 값으로 바꾸는 콜백

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
            System.out.println("Hello " + Thread.currentThread().getName());
            return "Hello";
        }).thenApply((s) -> {
            System.out.println(Thread.currentThread().getName());
            return s.toUpperCase();
        });

        System.out.println(future.get());

• thenAccept(Consumer): 리턴값을 또 다른 작업을 처리하는 콜백 (리턴 없이)

CompletableFuture<Void> future = CompletableFuture.supplyAsync(() -> {
            System.out.println("Hello " + Thread.currentThread().getName());
            return "Hello";
        }).thenAccept((s) -> {
            System.out.println(Thread.currentThread().getName());
            System.out.println(s.toUpperCase());
        });

        future.get();

• thenRun(Runable): 리턴값 받지 않고 다른 작업을 처리하는 콜백

CompletableFuture<Void> future = CompletableFuture.supplyAsync(() -> {
            System.out.println("Hello " + Thread.currentThread().getName());
            return "Hello";
        }).thenAccept((s) -> {
            System.out.println(Thread.currentThread().getName());
            System.out.println(s.toUpperCase());
        });

        future.get();

• 콜백 자체를 또 다른 쓰레드에서 실행핧 수 있다.