CompletionService를 사용하여 미래 목록 대기를 최적화하고 예외를 효율적으로 처리할 수 있는 방법은 무엇입니까?

CompletionService로 미래 목록 대기 최적화

미래 목록을 작업할 때 미래 목록이 완료될 때까지 효율적으로 기다리거나 예외를 처리하는 것이 중요합니다. 불필요한 지연을 방지하세요.

future 목록을 반환하는 다음 메소드가 있다고 가정해 보겠습니다.

List<Future<O>> futures = getFutures();

완료를 기다리거나 예외를 포착하려면 다음과 같은 순진한 접근 방식을 사용할 수 있습니다.

wait() {
  for(Future f : futures) {
    try {
      f.get();
    } catch(Exception e) {
       //Specific exception handling
       //Exception in a future, stop waiting
       return;
    }
  }
}

그러나 이 접근 방식은 이전 미래의 예외에 관계없이 각 미래를 기다립니다.

해결책은 CompletionService를 사용하여 미래를 사용할 수 있게 되면 받는 것입니다. 예외가 발생하면 다른 작업을 취소할 수 있습니다.

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

//Submit tasks
for(int i = 0; i < 4; i++) {
  completionService.submit(() -> {
    ...
    return result;
  });
}

int received = 0;
boolean errors = false;

while(received < 4 && !errors) {
  Future<SomeResult> resultFuture = completionService.take(); //Blocks if none available
  try {
    SomeResult result = resultFuture.get();
    received++;
    ... //Process result
  } catch(Exception e) {
    //Log and set error flag
    errors = true;
  }
}

이 접근 방식에서는 작업이 실행자에게 제출되고 완료된 작업이 완료 서비스를 통해 수신됩니다. 수신된 작업에서 예외가 발생하면 while 루프가 종료되고 실행기의 shutdownNow() 메서드를 사용하여 나머지 작업을 취소할 수 있습니다.

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