쓰레드 풀

• Executors & ExecutorService 사용하여 구현
  • java.util.concurrent 패키지에서 제공
• 많은 쓰레드 작업이 필요할 때 동시에 돌아가는 쓰레드들의 개수 제한
  • 너무 많은 쓰레드 작업으로 인한 부하 방지
• 쓰레드를 그때그때 생성/제거하지 않음
  • 주어진 개수만큼 쓰레드들을 만든 뒤 재사용
• 개발자가 직접 쓰레드를 생성하고 조작할 필요 없음
  • Runnable을 대기열에 추가하면 자리가 나는대로 태워보냄
  • 쓰레드들을 쓰레드 풀이 자동으로 관리함

🪣 동굴 물 퍼내기 예제

• 물이 40 들어찬 동굴에서 물이 20 남을때까지 펌핑
• ⭐ 한 번에 5명이 들어가서 펌핑할 수 있음
  • 쓰레드 (🪣 양동이) 가 5개 있음
  • 각 펌핑은 5초 소요
• 0.5초마다 지원자 (🦺 Runnable) 한 명씩 투입
  • 양동이가 모두 사용중이면 자리가 날 때까지 대기

📁 ex01

☕ Cave.java

public class Cave {
    private int water = 40;

    public int getWater() {
        return water;
    }
    public void pump() {
        if (getWater() > 0) water--;
    }
}

☕ VolunteerRun.java

public class VolunteerRun implements Runnable {
    private static int lastNo = 0;
    private static int working = 0;
    
    private int no;
    private Cave cave;
    
    public VolunteerRun(Cave cave) {
        this.no = ++lastNo;
        this.cave = cave;

        System.out.printf(
                "🦺 %d번 지원자 투입 (남은 물 양: %d)%n", no, cave.getWater()
        );
    }

    @Override
    public void run() {
        working++;
        System.out.printf(
                "🪣 %d번 지원자 시작 (현재 %d명 펌핑중, 남은 물 %d)%n",
                no, working, cave.getWater()
        );

        try { Thread.sleep(5000);
        } catch (InterruptedException e) {

            //  💡 아래의 return이 없다면 shutdownNow를 해도 중단되지 않음
            //  - 주석해제하고 shutdownNow 버전으로 다시 실행해 볼 것
            //working--;
            //System.out.printf(
            //        "🛑 %d번 지원자 중단 (현재 %d명 펌핑중, 남은 물 %d)%n",
            //        no, working, cave.getWater()
            //);
            //return;
        }

        cave.pump();
        working--;
        System.out.printf(
                "✅ %d번 지원자 완료 (현재 %d명 펌핑중, 남은 물 %d)%n",
                no, working, cave.getWater()
        );
    }
}

☕ Main.java