ExecutorService 심화

Java code

import java.util.concurrent.*;
import java.util.*;

public class ExecutorServiceAdvanced {
    public static void main(String[] args) throws Exception {
        // 고정 크기 스레드 풀
        ExecutorService fixed = Executors.newFixedThreadPool(4);

        // 캐시 스레드 풀 (필요 시 생성, 60초 유휴 시 제거)
        ExecutorService cached = Executors.newCachedThreadPool();

        // 단일 스레드 (순서 보장)
        ExecutorService single = Executors.newSingleThreadExecutor();

        // 태스크 제출
        List<Future<String>> futures = new ArrayList<>();
        for (int i = 0; i < 10; i++) {
            final int id = i;
            futures.add(fixed.submit(() -> {
                Thread.sleep(100);
                return "결과-" + id;
            }));
        }

        // 결과 수집
        for (Future<String> f : futures) {
            System.out.println(f.get(5, TimeUnit.SECONDS));
        }

        // invokeAll — 모두 완료될 때까지 대기
        List<Callable<String>> tasks = List.of(
            () -> "A", () -> "B", () -> "C");
        List<Future<String>> results = fixed.invokeAll(tasks);

        // 종료 (필수!)
        fixed.shutdown();
        if (!fixed.awaitTermination(10, TimeUnit.SECONDS)) {
            fixed.shutdownNow();
        }
        cached.shutdown();
        single.shutdown();
    }
}