Java ExecutorService 작업에서 예외를 처리하는 방법은 무엇입니까?

Java ExecutorService 작업의 예외 처리

Java의 ThreadPoolExecutor를 활용하여 제한된 스레드 풀 크기로 동시에 작업을 실행할 때 작업 중에 발생할 수 있는 잠재적인 예외를 관리하는 것이 중요합니다. 실행. 그러나 이 목적으로 afterExecute 메소드를 사용하면 예상대로 작동하지 않을 수 있습니다.

문제:

제공된 예에서:

protected void afterExecute(Runnable r, Throwable t) {
    super.afterExecute(r, t);
    if(t != null) {
        System.out.println("Got an error: " + t);
    } else {
        System.out.println("Everything's fine--situation normal!");
    }
}

afterExecute 메서드는 작업에서 예외가 발생할 때 호출되지 않습니다. 대신, 예외가 발생했는데도 출력에 "모든 것이 정상입니다"라고 잘못 표시됩니다. submit(Callable c) 대신 submit(Runnable r)을 사용하면 예외가 발생하지 않기 때문이다.

Callable vs. Runnable

효과적으로 프로세스 작업 예외가 발생하는 경우 ThreadPoolExecutor에 작업을 제출할 때 Runnable 대신 Callable을 사용하는 것이 좋습니다. Callable의 call() 메소드는 확인된 예외를 발생시킬 수 있으며, 이는 Future.get()을 통해 호출 스레드로 다시 전파됩니다.

예:

Callable<String> task = ...
Future<String> future = executor.submit(task);

// Do something else while task executes...

try {
    String result = future.get();
} catch (ExecutionException ex) {
    Throwable cause = ex.getCause();
    // Handle the exception as necessary
}

If Callable.call() 메소드가 예외를 발생시키면 ExecutionException으로 래핑되고 Future.get()에 의해 발생됩니다. 이를 통해 호출 스레드에서 예외를 적절하게 처리할 수 있습니다.

참고: 이 솔루션은 Future.get() 호출 중에 호출 스레드를 차단할 수 있다는 점에 유의하는 것이 중요합니다. 고급 오류 처리 및 복구 시나리오의 경우 특수 오류 처리 프레임워크 또는 사용자 정의 구현을 사용하는 것이 좋습니다.

위 내용은 Java ExecutorService 작업에서 예외를 처리하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!