찾다
Javajava지도 시간Java 9에서 비동기 프로그래밍 및 동시성 제어를 위해 CompletableFuture를 사용하는 방법

CompletableFuture를 사용하여 Java 9에서 비동기 프로그래밍 및 동시성 제어를 구현하는 방법

소개:
현대 애플리케이션에서 고성능 및 높은 동시성에 대한 수요가 증가함에 따라 비동기 프로그래밍 및 동시성 제어는 개발에서 일반적인 문제가 되었습니다. Java 9에 도입된 CompletableFuture 클래스는 비동기 작업을 처리하는 강력한 메커니즘을 제공하고 동시성 제어를 구현하는 간단하고 우아한 방법을 제공합니다. 이 기사에서는 Java 9의 CompletableFuture의 기본 개념을 소개하고 CompletableFuture를 사용하여 비동기 프로그래밍 및 동시성 제어를 구현하는 방법을 보여주는 몇 가지 샘플 코드를 제공합니다.

1. CompletableFuture 소개

CompletableFuture는 Java 8에 도입된 비동기 프로그래밍 메커니즘을 보완한 것입니다. Future 및 CompletionStage 인터페이스를 구현하는 클래스입니다. Future 인터페이스는 완료되지 않을 수 있는 비동기 작업의 결과를 나타내는 데 사용되는 반면, CompletionStage 인터페이스는 비동기적으로 수행될 수 있는 계산(작업 트리거 및 결과 반환 포함)과 후속 작업을 표현하는 데 사용됩니다. 계산이 완료된 후 트리거됩니다. CompletableFuture 클래스는 이러한 인터페이스를 사용하는 단순화된 방법을 제공하고 비동기 작업을 처리하기 위한 보다 강력한 기능을 제공합니다.

2. 기본 사용 예

  1. CompletableFuture 객체 생성

먼저 비동기 계산 결과를 나타내는 CompletableFuture 객체를 생성해야 합니다. CompletableFuture 클래스는completeFuture, SupplyAsync 등과 같은 객체를 생성하기 위한 다양한 정적 메서드를 제공합니다. 다음은 샘플 코드입니다.

CompletableFuture<String> future = CompletableFuture.completedFuture("Hello, CompletableFuture!");

위 코드에서는completeFuture 메서드를 사용하여 완성된 CompletableFuture 객체를 생성하고 이를 계산 결과로 문자열로 전달합니다.

  1. 비동기 계산 트리거

다음으로 비동기 계산을 트리거하고 이를 이전 단계에서 생성된 CompletableFuture 개체와 연결해야 합니다. CompletableFuture 클래스는 이를 달성하기 위해 runAsync 및 SupplyAsync라는 두 가지 메서드를 제공합니다. 전자는 결과를 반환하지 않는 비동기 작업을 수행하는 데 사용되고, 후자는 결과를 반환하는 비동기 작업을 수행하는 데 사용됩니다. 다음은 샘플 코드입니다.

CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
    // 异步计算,返回一个整数结果
    return 42;
});

위 코드에서는 SupplyAsync 메서드를 사용하여 정수 결과를 반환하는 비동기적으로 실행되는 계산을 생성합니다.

  1. 비동기 계산 결과 처리

비동기 계산이 완료되면 CompletableFuture 객체의 메서드를 호출하여 계산 결과를 처리할 수 있습니다. CompletableFuture 클래스는 결과를 처리하기 위한 thenApply, thenAccept 등과 같은 다양한 메서드를 제공합니다. 샘플 코드는 다음과 같습니다.

CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
    // 异步计算,返回一个整数结果
    return 42;
});
future.thenApply(result -> {
    // 处理结果并返回一个新的结果
    return result * 2;
})
.thenAccept(result -> {
    // 处理最终结果
    System.out.println("Final result: " + result);
});

위 코드에서는 비동기 계산이 완료된 후 결과를 처리하고 새로운 결과를 반환하기 위해 thenApply 메서드를 호출합니다. 그런 다음 최종 결과를 처리하고 인쇄하기 위해 thenAccept 메서드를 호출했습니다.

3. 동시성 제어 예제

CompletableFuture는 비동기 프로그래밍 외에도 동시성 제어를 구현하는 몇 가지 방법도 제공합니다. 가장 일반적으로 사용되는 방법에는 anyOf, allOf 및 Join이 있습니다.

  1. anyOf 메소드

anyOf 메소드는 여러 CompletableFuture 중 하나가 완료되기를 기다리는 데 사용됩니다. 첫 번째 완성된 CompletableFuture 객체의 결과를 평가하는 새로운 CompletableFuture 객체를 반환합니다. 다음은 샘플 코드입니다.

CompletableFuture<Integer> future1 = CompletableFuture.supplyAsync(() -> {
    // 异步计算1
    return 1;
});
CompletableFuture<Integer> future2 = CompletableFuture.supplyAsync(() -> {
    // 异步计算2
    return 2;
});
CompletableFuture<Object> resultFuture = CompletableFuture.anyOf(future1, future2);
resultFuture.thenAccept(result -> {
    System.out.println("First result: " + result);
});

위 코드에서는 anyOf 메소드를 사용하여 future1 또는 future2가 계산되기를 기다리고 결과를 인쇄합니다.

  1. allOf 메소드

allOf 메소드는 여러 CompletableFutures의 모든 계산이 완료되기를 기다리는 데 사용됩니다. Void 값(null)으로 평가되는 새로운 CompletableFuture 객체를 반환합니다. 다음은 샘플 코드입니다.

CompletableFuture<Integer> future1 = CompletableFuture.supplyAsync(() -> {
    // 异步计算1
    return 1;
});
CompletableFuture<Integer> future2 = CompletableFuture.supplyAsync(() -> {
    // 异步计算2
    return 2;
});
CompletableFuture<Void> resultFuture = CompletableFuture.allOf(future1, future2);
resultFuture.thenRun(() -> {
    System.out.println("All calculations are completed.");
});

위 코드에서는 allOf 메서드를 사용하여 future1 및 future2의 모든 계산이 완료되기를 기다리고 완료 메시지를 인쇄합니다.

  1. join 메소드

join 메소드는 CompletableFuture의 계산 결과를 기다리고 결과를 반환하는 데 사용됩니다. 계산 중에 예외가 발생하면 예외가 발생합니다. 다음은 샘플 코드입니다.

CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
    // 异步计算,返回一个整数结果
    return 42;
});
int result = future.join();
System.out.println("Result: " + result);

위 코드에서는 조인 메서드를 사용하여 미래 계산이 완료되기를 기다리고 그 결과를 얻습니다.

요약:

이 기사에서는 Java 9의 CompletableFuture의 기본 개념을 소개하고 CompletableFuture를 사용하여 비동기 프로그래밍 및 동시성 제어를 구현하는 방법을 보여주는 몇 가지 샘플 코드를 제공합니다. CompletableFuture를 사용하면 간단하고 우아한 방식으로 비동기 작업을 처리하고 동시 계산을 유연하게 제어할 수 있습니다. 이 예제가 CompletableFuture를 이해하고 사용하는 데 도움이 되기를 바랍니다.

위 내용은 Java 9에서 비동기 프로그래밍 및 동시성 제어를 위해 CompletableFuture를 사용하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
고급 Java 프로젝트 관리, 구축 자동화 및 종속성 해상도에 Maven 또는 Gradle을 어떻게 사용합니까?고급 Java 프로젝트 관리, 구축 자동화 및 종속성 해상도에 Maven 또는 Gradle을 어떻게 사용합니까?Mar 17, 2025 pm 05:46 PM

이 기사에서는 Java 프로젝트 관리, 구축 자동화 및 종속성 해상도에 Maven 및 Gradle을 사용하여 접근 방식과 최적화 전략을 비교합니다.

적절한 버전 및 종속성 관리로 Custom Java 라이브러리 (JAR Files)를 작성하고 사용하려면 어떻게해야합니까?적절한 버전 및 종속성 관리로 Custom Java 라이브러리 (JAR Files)를 작성하고 사용하려면 어떻게해야합니까?Mar 17, 2025 pm 05:45 PM

이 기사에서는 Maven 및 Gradle과 같은 도구를 사용하여 적절한 버전 및 종속성 관리로 사용자 정의 Java 라이브러리 (JAR Files)를 작성하고 사용하는 것에 대해 설명합니다.

카페인 또는 구아바 캐시와 같은 라이브러리를 사용하여 자바 애플리케이션에서 다단계 캐싱을 구현하려면 어떻게해야합니까?카페인 또는 구아바 캐시와 같은 라이브러리를 사용하여 자바 애플리케이션에서 다단계 캐싱을 구현하려면 어떻게해야합니까?Mar 17, 2025 pm 05:44 PM

이 기사는 카페인 및 구아바 캐시를 사용하여 자바에서 다단계 캐싱을 구현하여 응용 프로그램 성능을 향상시키는 것에 대해 설명합니다. 구성 및 퇴거 정책 관리 Best Pra와 함께 설정, 통합 및 성능 이점을 다룹니다.

캐싱 및 게으른 하중과 같은 고급 기능을 사용하여 객체 관계 매핑에 JPA (Java Persistence API)를 어떻게 사용하려면 어떻게해야합니까?캐싱 및 게으른 하중과 같은 고급 기능을 사용하여 객체 관계 매핑에 JPA (Java Persistence API)를 어떻게 사용하려면 어떻게해야합니까?Mar 17, 2025 pm 05:43 PM

이 기사는 캐싱 및 게으른 하중과 같은 고급 기능을 사용하여 객체 관계 매핑에 JPA를 사용하는 것에 대해 설명합니다. 잠재적 인 함정을 강조하면서 성능을 최적화하기위한 설정, 엔티티 매핑 및 모범 사례를 다룹니다. [159 문자]

Java의 클래스로드 메커니즘은 다른 클래스 로더 및 대표 모델을 포함하여 어떻게 작동합니까?Java의 클래스로드 메커니즘은 다른 클래스 로더 및 대표 모델을 포함하여 어떻게 작동합니까?Mar 17, 2025 pm 05:35 PM

Java의 클래스 로딩에는 부트 스트랩, 확장 및 응용 프로그램 클래스 로더가있는 계층 적 시스템을 사용하여 클래스로드, 링크 및 초기화 클래스가 포함됩니다. 학부모 위임 모델은 핵심 클래스가 먼저로드되어 사용자 정의 클래스 LOA에 영향을 미치도록합니다.

분산 컴퓨팅에 Java의 RMI (원격 메소드 호출)를 어떻게 사용할 수 있습니까?분산 컴퓨팅에 Java의 RMI (원격 메소드 호출)를 어떻게 사용할 수 있습니까?Mar 11, 2025 pm 05:53 PM

이 기사에서는 분산 응용 프로그램을 구축하기위한 Java의 원격 메소드 호출 (RMI)에 대해 설명합니다. 인터페이스 정의, 구현, 레지스트리 설정 및 클라이언트 측 호출을 자세히 설명하여 네트워크 문제 및 보안과 같은 문제를 해결합니다.

네트워크 통신에 Java의 Sockets API를 어떻게 사용합니까?네트워크 통신에 Java의 Sockets API를 어떻게 사용합니까?Mar 11, 2025 pm 05:53 PM

이 기사는 네트워크 통신을위한 Java의 소켓 API, 클라이언트 서버 설정, 데이터 처리 및 리소스 관리, 오류 처리 및 보안과 같은 중요한 고려 사항에 대해 자세히 설명합니다. 또한 성능 최적화 기술, i

Java에서 사용자 정의 네트워킹 프로토콜을 어떻게 만들 수 있습니까?Java에서 사용자 정의 네트워킹 프로토콜을 어떻게 만들 수 있습니까?Mar 11, 2025 pm 05:52 PM

이 기사에서는 맞춤형 Java 네트워킹 프로토콜을 작성합니다. 프로토콜 정의 (데이터 구조, 프레임, 오류 처리, 버전화), 구현 (소켓 사용), 데이터 직렬화 및 모범 사례 (효율성, 보안, Mainta를 포함합니다.

See all articles

핫 AI 도구

Undresser.AI Undress

Undresser.AI Undress

사실적인 누드 사진을 만들기 위한 AI 기반 앱

AI Clothes Remover

AI Clothes Remover

사진에서 옷을 제거하는 온라인 AI 도구입니다.

Undress AI Tool

Undress AI Tool

무료로 이미지를 벗다

Clothoff.io

Clothoff.io

AI 옷 제거제

AI Hentai Generator

AI Hentai Generator

AI Hentai를 무료로 생성하십시오.

인기 기사

R.E.P.O. 에너지 결정과 그들이하는 일 (노란색 크리스탈)
3 몇 주 전By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O. 최고의 그래픽 설정
3 몇 주 전By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O. 아무도들을 수없는 경우 오디오를 수정하는 방법
3 몇 주 전By尊渡假赌尊渡假赌尊渡假赌
WWE 2K25 : Myrise에서 모든 것을 잠금 해제하는 방법
3 몇 주 전By尊渡假赌尊渡假赌尊渡假赌

뜨거운 도구

스튜디오 13.0.1 보내기

스튜디오 13.0.1 보내기

강력한 PHP 통합 개발 환경

Atom Editor Mac 버전 다운로드

Atom Editor Mac 버전 다운로드

가장 인기 있는 오픈 소스 편집기

드림위버 CS6

드림위버 CS6

시각적 웹 개발 도구

ZendStudio 13.5.1 맥

ZendStudio 13.5.1 맥

강력한 PHP 통합 개발 환경

에디트플러스 중국어 크랙 버전

에디트플러스 중국어 크랙 버전

작은 크기, 구문 강조, 코드 프롬프트 기능을 지원하지 않음