ㅏ CompltableFuture 비동기 프로그래밍에 사용됩니다. 비동기 프로그래밍은 비차단 코드를 작성하는 것을 의미합니다. 메인 애플리케이션 스레드가 아닌 별도의 스레드에서 작업을 실행하고 해당 작업의 진행, 완료 또는 실패를 메인 스레드에 알립니다.

이런 방식으로 메인 스레드는 작업이 완료될 때까지 차단하거나 기다리지 않습니다. 다른 작업은 병렬로 실행됩니다. 병렬화는 프로그램의 성능을 향상시킵니다.

CompletableFuture는 Java의 클래스입니다. java.util.cocurrent 패키지에 속합니다. CompletionStage 및 Future 인터페이스를 구현합니다.

ml에서 온스로

완료단계

• 작업을 수행하고 다른 완료 단계가 완료되면 값을 반환합니다.
• 다른 작업을 트리거할 수 있는 작업에 대한 모델입니다.

따라서 이는 체인의 요소입니다.

둘 이상의 스레드가 완료를 시도하는 경우(예외적으로 완료하거나 CompletableFuture를 취소함) 그 중 하나만 성공합니다.

미래 vs. CompletableFuture

CompletableFuture는 Java 8에 도입된 Java Future API의 확장입니다.

Future는 비동기 프로그래밍에 사용됩니다. isDone()과 get()이라는 두 가지 메서드를 제공합니다. 메서드는 계산이 완료되면 계산 결과를 검색합니다.

미래의 한계

• 미래는 상호 완전할 수 없습니다.
• 차단하지 않고는 Future의 결과에 대해 추가 조치를 수행할 수 없습니다.
• Future에는 예외 처리가 없습니다.
• 여러 미래를 결합할 수는 없습니다.

Future에는 너무 많은 제한이 있으므로 CompletableFuture가 있습니다. CompletableFuture는 여러 Future를 생성하고 연결하고 결합하기 위한 광범위한 방법을 제공합니다. 또한 포괄적인 예외 처리 지원도 제공합니다.

CompletableFuture 만들기

인수가 없는 다음 생성자를 사용해야만 CompletableFuture를 만들 수 있습니다.

java의 string.replaceall

 CompletableFuture CompletableFuture = new CompletableFuture(); 

예

가장 자주 사용되는 CompletableFuture 메서드는 다음과 같습니다.

공급비동기화():비동기식으로 작업을 완료합니다. 공급자의 결과는 기본적으로 ForkJoinPool.commonPool()의 작업에 의해 실행됩니다. SupplyAsync() 메서드는 다른 메서드를 적용할 수 있는 CompletableFuture를 반환합니다.그런 다음 적용():이 메서드는 함수를 인수로 받아들입니다. 이 단계가 정상적으로 완료되면 새 CompletableStage를 반환합니다. 새로운 단계는 제공된 함수에 대한 인수로 사용됩니다.가입하다():메서드는 완료되면 결과 값을 반환합니다. 또한 예외적으로 완료되면 CompletionException(확인되지 ​​않은 예외)이 발생합니다.

 import java.util.Arrays; import java.util.List; import java.util.concurrent.CompletableFuture; public class CompletableFutureExample1 { public static void main(String[] args) { try { List list = Arrays.asList(5,9,14); list.stream().map(num->CompletableFuture.supplyAsync(()->getNumber(num))).map(CompletableFuture->CompletableFuture.thenApply(n- >n*n)).map(t->t.join()).forEach(s->System.out.println(s)); } catch (Exception e) { e.printStackTrace(); } } private static int getNumber(int a) { return a*a; } } 

산출:

자바 우선 순위 대기열

CompletableFuture의 예외 처리

5개의 CF를 나타내는 다음 그림을 고려하십시오.

5개의 CF가 실행 중이고 CF21에서 예외가 발생했다고 가정하면 모든 종속 CF(CF31 및 CF41)에 오류가 발생합니다. 이는 다음을 의미합니다.

• isCompletedExceptionally() 메서드를 호출하면 true가 반환됩니다.
• get() 호출은 루트 예외를 발생시키는 ExecutionException을 발생시킵니다.

예외를 제외하고 CF30을 생성한 다음 그림을 고려하십시오.

CF21이 정상적으로 실행되면 CF30은 값만 전송합니다. 예외가 발생하면 CF30이 이를 처리하고 CF31에 대한 값을 생성합니다.

예외를 처리하는 방법에는 세 가지가 있습니다.

 public CompletableFuture exceptionally(Function function); public CompletableFuture hadle(BiFunction bifunction); public CompletableFuture whenComplete(BiConsumer action);