CompletableFuture를 사용하여 Java에서 비동기 동시 프로그래밍을 구현하는 방법은 무엇입니까?

CompletableFuture를 사용하여 Java에서 비동기 동시 프로그래밍 구현: CompletableFuture 만들기: 매개변수 없는 메서드를 매개변수로 받고 값을 반환하는 CompletableFuture.supplyAsync()를 통해 CompletableFuture를 만듭니다. 완료 상황 처리: 작업 완료, 예외 및 취소 상황을 처리하려면 whenComplete(), thenApply(), thenAccept(),Exceptionly() 및 handler() 메서드를 사용하십시오. CompletableFutures 결합: thenCompose() 메서드를 사용하여 두 개의 CompletableFutures를 연결합니다. 실제 사례: CompletableFuture를 사용하여 데이터베이스에서 사용자 목록을 병렬로 가져오고 원격 API에서 각 사용자의 세부 정보를 가져오는 방법을 보여줍니다.

CompletableFuture를 사용하여 Java에서 비동기 동시 프로그래밍을 구현하는 방법은 무엇입니까?

Introduction

CompletableFuture는 작업을 비동기적으로 실행하고 완료를 처리할 수 있도록 Java 8에 도입된 동시성 유틸리티 클래스입니다. 이는 기존 스레드보다 동시성을 관리하는 더 우아하고 간단한 방법을 제공합니다.

기본 사용법

CompletableFuture를 생성하려면 공급자를 매개변수로 허용하는 CompletableFuture.supplyAsync() 메서드를 사용할 수 있습니다. 공급자는 매개 변수가 없는 메서드이며 값을 반환합니다.

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "Hello");

완료 처리

CompletableFuture의 주요 기능 중 하나는 작업 완료를 처리하는 기능입니다. 완료, 예외 및 취소 상황을 처리하는 다양한 방법을 제공합니다.

• whenComplete(): 완료 성공 여부에 관계없이 작업이 완료된 후 지정된 작업을 실행합니다. whenComplete()：在任务完成后执行指定的动作，无论是否完成成功。
• thenApply()：在任务成功完成后执行指定的函数并返回一个新值。
• thenAccept()：在任务成功完成后执行指定的消费者。
• exceptionally()：在任务失败后执行指定的异常处理程序并返回一个新值。
• handle()：在任务完成后执行指定的函数，无论任务是否完成成功，并返回一个新值。

组合 CompletableFuture

CompletableFuture 可以组合起来创建更复杂的并行任务。例如，您可以使用 thenCompose()

thenApply(): 지정된 함수를 실행하고 작업이 성공적으로 완료된 후 새 값을 반환합니다.

thenAccept(): 작업이 성공적으로 완료된 후 지정된 소비자를 실행합니다.

Exceptionally(): 지정된 예외 처리기를 실행하고 작업이 실패한 후 새 값을 반환합니다.

handle(): 작업 성공 여부에 관계없이 작업이 완료된 후 지정된 함수를 실행하고 새 값을 반환합니다.

• CompletableFutures 결합

CompletableFutures를 결합하여 더 복잡한 병렬 작업을 만들 수 있습니다. 예를 들어, thenCompose() 메서드를 사용하여 두 개의 CompletableFuture를 함께 연결할 수 있습니다:

CompletableFuture<Integer> future1 = CompletableFuture.supplyAsync(() -> 1);
CompletableFuture<Integer> future2 = CompletableFuture.supplyAsync(() -> 2);

future1.thenCompose(x -> future2.thenApply(y -> x + y));

실용 사례🎜🎜🎜병렬로 실행해야 하는 다음 작업이 있다고 가정합니다. 🎜🎜🎜 데이터베이스 사용자 목록에서 가져오기 🎜🎜 원격 API에서 각 사용자의 세부 정보 가져오기 🎜🎜🎜 CompletableFuture를 사용하여 이를 달성할 수 있습니다. 🎜

CompletableFuture<List<User>> futureUsers = CompletableFuture.supplyAsync(() -> getUsersFromDatabase());

CompletableFuture<Map<Integer, UserDetail>> futureDetails = CompletableFuture.supplyAsync(() -> {
    List<User> users = futureUsers.get();
    return getUsersDetailsFromApi(users);
});

CompletableFuture<List<User>> combinedFuture = futureUsers.thenCombine(futureDetails, (users, details) -> {
    for (User user : users) {
        user.setDetails(details.get(user.getId()));
    }
    return users;
});

🎜 이 예에서는 CompletableFuture를 사용하여 다양한 소스에서 데이터를 병렬로 가져와 결합하는 방법을 보여줍니다. 🎜

위 내용은 CompletableFuture를 사용하여 Java에서 비동기 동시 프로그래밍을 구현하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!