Java ExecutorService를 정상적으로 종료

Executor는 Java 애플리케이션에서 작업을 동시에 관리하고 실행하는 편리한 방법입니다. 그러나 제대로 종료하지 않으면 예기치 않은 동작이나 성능 문제가 발생할 수 있습니다. 이 가이드는 모든 작업이 종료되거나 취소되도록 ExecutorService를 올바르게 종료하는 방법에 대한 자세한 설명을 제공합니다.

ExecutorService 종료 이해

ExecutorService는 두 가지 기본 종료 방법을 제공합니다. :

• shutdown(): 새 작업이 제출되는 동안 제출되는 것을 방지합니다. 기존 작업을 완료하도록 허용합니다.
• shutdownNow(): 모든 실행 및 대기 작업을 중지하려고 시도하고 처리되지 않은 작업 목록을 반환합니다.

다음을 수행하는 것이 중요합니다. 종료해도 모든 작업이 종료된다는 보장은 없습니다. 인터럽트에 응답하지 못하거나 장시간 실행되는 작업이 있는 작업은 활성 상태로 남아 있을 수 있습니다.

권장되는 종료 절차

Oracle 문서에서는 정상적인 종료를 위해 다음 접근 방식을 제안합니다.

void shutdownAndAwaitTermination(ExecutorService pool) {
    pool.shutdown();
    try {
        // Wait for existing tasks to terminate
        if (!pool.awaitTermination(60, TimeUnit.SECONDS)) {
            pool.shutdownNow();
            // Wait for tasks to respond to cancellation
            if (!pool.awaitTermination(60, TimeUnit.SECONDS))
                System.err.println("Pool did not terminate");
        }
    } catch (InterruptedException ie) {
        pool.shutdownNow();
        Thread.currentThread().interrupt();
    }
}

이 접근 방식을 사용하면 새 제출을 방지하면서 기존 작업을 완료할 수 있습니다. 종료 프로세스가 예상보다 오래 걸리는 경우

if (!pool.awaitTermination(60, TimeUnit.SECONDS))

를

while (!pool.awaitTermination(60, TimeUnit.SECONDS))

작업을 계속 대기 완료.

종료 방법 요약

• shutdown(): 새 작업 수락을 중지하지만 기존 작업을 완료하도록 허용합니다.
• shutdownNow(): 모든 실행 및 대기 작업을 중지하고 처리되지 않은 작업을 반환합니다. jobs.
• awaitTermination(긴 시간 초과, TimeUnit 단위): 모든 작업이 완료되거나 시간 초과가 발생하거나 현재 스레드가 중단될 때까지 차단합니다.