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

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

CompletionService로 불필요한 대기 방지

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

Executor executor = Executors.newFixedThreadPool(4);
CompletionService completionService = new ExecutorCompletionService(executor);

// Submit tasks to the service
for (int i = 0; i () {
        @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  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

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