Futures 목록을 효율적으로 기다리고 예외를 처리하는 방법은 무엇입니까?

퓨처 목록에서 효율적으로 대기

퓨처 목록을 처리할 때 목표는 완료되거나 다음이 발생할 때까지 기다리는 것입니다. 미래에는 예외입니다. f.get()에 대한 개별 호출과 관련된 순진한 접근 방식은 초기에 예외가 발생할 경우 불필요한 대기로 이어질 수 있습니다.

CompletionService로 불필요한 대기 방지

이 문제를 해결하려면 문제가 발생하면 CompletionService 클래스가 작동합니다. 이를 통해 비동기 작업을 실행하고 결과를 사용할 수 있게 되면 스레드로부터 안전한 방식으로 검색할 수 있습니다. 사용 방법은 다음과 같습니다.

<code class="java">Executor executor = Executors.newFixedThreadPool(4);
CompletionService<SomeResult> completionService = new ExecutorCompletionService<>(executor);

// Submit tasks to the service
for (int i = 0; i < 4; i++) {
    completionService.submit(new Callable<SomeResult>() {
        @Override
        public SomeResult call() {
            // Task logic here
            return result;
        }
    });
}

int received = 0;
boolean errors = false;

// Loop until all tasks are complete or an error occurs
while (received < 4 && !errors) {
    Future<SomeResult> resultFuture = completionService.take(); // Blocks if nothing available
    try {
        SomeResult result = resultFuture.get();
        received++;
        // Process result here
    } catch (Exception e) {
        // Log error
        errors = true;
    }
}

// Consider canceling remaining tasks if an error occurred</code>

CompletionService 접근 방식을 사용하면 작업 완료를 실시간으로 모니터링하고 오류가 발생하면 추가 처리를 중단하여 불필요한 대기를 피할 수 있습니다.

위 내용은 Futures 목록을 효율적으로 기다리고 예외를 처리하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!