Java Executors 및 CompletableFuture를 사용하여 비차단 방식으로 작업을 실행하는 방법은 무엇입니까?

Java 실행기를 사용한 비차단 작업 실행

여러 작업 대기열로 작업할 때 과도한 리소스를 소비할 수 있는 차단 작업을 피하는 것이 중요합니다. 스택 공간. 이 문서에서는 Java의 java.util.concurrent 패키지를 활용하여 작업 완료 알림을 위한 콜백을 활용하여 차단 없이 실행기에 작업을 제출하는 방법을 살펴봅니다.

콜백 접근 방식

정의 작업의 원하는 결과 또는 완료 상태를 받아들이는 콜백 인터페이스. 작업과 콜백을 모두 허용하는 래퍼 클래스를 구현합니다. 작업이 완료되면 래퍼는 콜백을 호출합니다.

CompletableFuture 및 비동기 실행

Java 8에서는 비동기 및 조건을 구성하기 위한 보다 정교한 메커니즘을 제공하는 CompletableFuture를 도입했습니다. 파이프라인. 스레드 풀에서 작업을 실행하는 CompletableFuture를 만듭니다. 그런 다음 작업 완료 시 호출될 future에 리스너를 연결합니다.

예

다음 코드 조각은 비차단 작업 실행을 위해 CompletableFuture를 사용하는 방법을 보여줍니다. :

import java.util.concurrent.CompletableFuture;

// Service class to perform the task
class ExampleService {
    public String work() {
        // Simulated work
        char[] str = new char[5];
        ThreadLocalRandom current = ThreadLocalRandom.current();
        for (int idx = 0; idx < str.length; ++idx)
            str[idx] = (char) ('A' + current.nextInt(26));
        String msg = new String(str);
        System.out.println("Generated message: " + msg);
        return msg;
    }
}

// Main class
public class Main {
    public static void main(String[] args) {
        ExampleService svc = new ExampleService();
        CompletableFuture<String> f = CompletableFuture.supplyAsync(svc::work);
        
        // Attach a listener to the future
        f.thenAccept(result -> System.out.println("Result: " + result));
        
        // Main method can continue execution without blocking
        System.out.println("Main method exiting");
    }
}

이 코드는 work() 메서드를 비동기적으로 실행하는 CompletableFuture를 생성합니다. thenAccept() 메서드는 CompletableFuture가 완료될 때 호출되는 리스너를 연결하여 작업의 비차단 실행을 허용합니다.

위 내용은 Java Executors 및 CompletableFuture를 사용하여 비차단 방식으로 작업을 실행하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!