Java ExecutorService 완벽 가이드, 스레드 풀로 효율적인 멀티스레드 관리하기

🔗 ExecutorService 기본 개념

Java에서 ExecutorService는 멀티스레드 작업을 효율적으로 관리하기 위한 인터페이스입니다.
기존에 Thread를 직접 생성하고 제어하는 방식은 간단하지만, 많은 요청을 처리하는 애플리케이션에서는 스레드 생성과 소멸의 비용이 커집니다.
ExecutorService는 스레드 풀(Thread Pool)을 사용하여 이 문제를 해결합니다.

스레드 풀은 미리 일정 개수의 스레드를 생성해두고, 작업이 들어오면 대기 중인 스레드가 이를 처리합니다.
작업이 끝나면 스레드는 종료되지 않고 다시 풀로 반환되어 재사용됩니다.
이 방식은 시스템 리소스를 절약하고 응답 속도를 향상시키는 장점이 있습니다.

📌 주요 특징

• ⚡스레드 재사용을 통한 리소스 절약
• ⚡작업 제출, 실행, 스케줄링을 위한 표준 API 제공
• ⚡스레드 생성, 관리, 종료를 자동 처리
• ⚡동시성 문제를 줄이고 안정성 향상

💻 ExecutorService 생성 방법

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class Main {
    public static void main(String[] args) {
        ExecutorService executor = Executors.newFixedThreadPool(5); // 스레드 5개 고정
        executor.submit(() -> System.out.println("작업 실행 중: " + Thread.currentThread().getName()));
        executor.shutdown();
    }
}

🛠️ 다양한 스레드 풀 유형

Java의 Executors 클래스는 여러 종류의 스레드 풀 생성 메서드를 제공합니다.
각 스레드 풀은 특성에 따라 적합한 사용 환경이 다르므로, 요구사항에 맞는 풀을 선택하는 것이 중요합니다.

📌 FixedThreadPool

고정된 개수의 스레드를 유지하는 풀입니다.
CPU나 작업 부하에 맞춰 스레드 수를 조절하여 과도한 리소스 사용을 방지합니다.

ExecutorService fixedPool = Executors.newFixedThreadPool(4);

📌 CachedThreadPool

필요할 때 스레드를 생성하고, 일정 시간 사용하지 않으면 스레드를 제거합니다.
짧은 시간에 많은 작업을 처리할 때 적합하지만, 과도한 스레드 생성에 주의해야 합니다.

ExecutorService cachedPool = Executors.newCachedThreadPool();

📌 SingleThreadExecutor

단일 스레드로 작업을 순차적으로 처리합니다.
작업 순서가 중요한 경우에 유용합니다.

ExecutorService singleExecutor = Executors.newSingleThreadExecutor();

📌 ScheduledThreadPool

작업을 일정 지연 후 실행하거나, 주기적으로 실행하는 데 사용됩니다.

ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(3);

⚙️ ExecutorService 사용 예제

ExecutorService를 사용하면 간단한 코드로 여러 작업을 동시에 처리할 수 있습니다.
특히 submit() 메서드는 Callable 또는 Runnable 작업을 실행하고, 필요하면 결과를 Future 객체로 받을 수 있습니다.

📌 Runnable 작업 실행

ExecutorService executor = Executors.newFixedThreadPool(3);

executor.submit(() -> {
    System.out.println("Runnable 작업 실행: " + Thread.currentThread().getName());
});

executor.shutdown();

📌 Callable 작업과 결과 반환

Callable은 Runnable과 달리 결과를 반환하고 예외를 던질 수 있습니다.
submit() 메서드로 실행하면 Future 객체를 통해 결과를 받을 수 있습니다.

import java.util.concurrent.*;

ExecutorService executor = Executors.newFixedThreadPool(2);

Callable<String> task = () -> {
    Thread.sleep(1000);
    return "작업 완료: " + Thread.currentThread().getName();
};

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

try {
    String result = future.get(); // 결과 대기
    System.out.println(result);
} catch (InterruptedException | ExecutionException e) {
    e.printStackTrace();
} finally {
    executor.shutdown();
}

🔌 스레드 풀 관리와 종료

ExecutorService를 사용하면서 중요한 점은 적절한 시점에 스레드 풀을 종료하는 것입니다.
스레드 풀이 계속 동작하면 애플리케이션이 종료되지 않거나 리소스가 낭비될 수 있습니다.
Java에서는 이를 위해 shutdown()과 shutdownNow() 메서드를 제공합니다.

shutdown()은 현재 제출된 작업은 모두 완료한 후 스레드 풀을 정상 종료합니다.
반면에 shutdownNow()는 즉시 작업을 중단하고 실행 중인 스레드를 강제로 종료하려 시도합니다.
따라서 가능하면 shutdown()을 사용하고, 불가피한 경우에만 shutdownNow()를 사용하는 것이 좋습니다.

📌 스레드 풀 종료 예제

executor.shutdown();

try {
    if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
        executor.shutdownNow();
    }
} catch (InterruptedException e) {
    executor.shutdownNow();
}

위 코드에서 awaitTermination() 메서드는 지정한 시간 동안 스레드 풀이 종료되기를 기다립니다.
만약 시간 내에 종료되지 않으면 shutdownNow()를 호출하여 강제 종료합니다.

💡 ExecutorService 사용 시 주의사항

ExecutorService를 활용할 때는 다음과 같은 주의사항을 반드시 숙지해야 안정적이고 효율적인 멀티스레드 환경을 유지할 수 있습니다.

⚠️ 스레드 누수 방지

스레드 풀을 생성한 후에는 반드시 shutdown() 또는 shutdownNow() 메서드를 호출하여 스레드 풀을 종료해야 합니다.
그렇지 않으면 애플리케이션이 정상 종료되지 않거나 메모리 누수가 발생할 수 있습니다.

⚠️ 작업 제출 시 예외 처리

ExecutorService에 제출하는 작업이 예외를 던질 수 있으므로, Runnable이나 Callable 내부에서 적절한 예외 처리를 구현해야 합니다.
특히 Callable 작업은 Future.get()에서 예외가 발생할 수 있으므로 이를 꼭 처리해야 합니다.

⚠️ 작업 대기 시간과 큐 관리

스레드 풀에 과도한 작업이 몰리면 대기 큐에 작업이 쌓여 지연이 발생할 수 있습니다.
필요에 따라 큐 크기를 제한하고, 작업 거부 정책(RejectedExecutionHandler)을 적절히 설정해 예기치 않은 동작을 방지해야 합니다.

⚠️ 스레드 풀 크기 결정

스레드 풀 크기는 CPU 코어 수, 작업 유형(CPU 바운드/IO 바운드), 시스템 리소스 등을 고려해 신중히 결정해야 합니다.
적절한 크기를 초과하면 컨텍스트 스위칭 비용이 증가하고 성능이 오히려 저하될 수 있습니다.

❓ 자주 묻는 질문 (FAQ)