14.9 스레드 풀 (ThreadPool)

// 방법 1: 일이 많아지면 유동적으로 알바생을 무한정 뽑고, 일이 없으면 줄이는 사무소
ExecutorService executorService = Executors.newCachedThreadPool();

// 방법 2: 항상 딱 5명의 정규직만 고용하여 운영하는 안정적인 사무소 (가장 많이 씀!)
ExecutorService executorService = Executors.newFixedThreadPool(5);

package ch14.sec09.exam01;

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

public class ExecutorServiceExample {
	public static void main(String[] args) {
		// 스레드풀 생성: 딱 5명의 정규직 직원만 고용하는 인력 사무소를 차림
		ExecutorService executorService = Executors.newFixedThreadPool(5);
		
		// (이곳에서 작업 생성과 처리 요청을 함)
		
		// 스레드풀 종료: "오늘 영업 끝! 하던 일 멈추고 다들 퇴근하세요!"
		executorService.shutdownNow();
	}
}

package ch14.sec09.exam02;

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

public class RunnableExecuteExample {
	public static void main(String[] args) {
		// 1000개의 메일(일거리) 생성
		String[][] mails = new String[1000][3];
		for (int i=0; i<mails.length; i++) {
			mails[i][0] = "admin@my.com";
			mails[i][1] = "member"+i+"@my.com";
			mails[i][2] = "신상품 입고";
		}

		// 인력 사무소 오픈: 5명의 직원 고용
		ExecutorService executorService = Executors.newFixedThreadPool(5);

		// 1000개의 일거리를 접수처(큐)에 넣기
		for (int i=0; i<1000; i++) {
			final int idx = i;
			// execute()로 접수: "결과 보고 필요 없음. 그냥 메일만 보내!"
			executorService.execute(new Runnable() {
				@Override
				public void run() {
					// 5명의 직원 중 대기실에서 쉬고 있던 누군가가 이 일을 맡음
					Thread thread = Thread.currentThread(); 
					String from = mails[idx][0];
					String to = mails[idx][1];
					String content = mails[idx][2];
					// "저(thread) 지금 메일 보냅니다!"
					System.out.println("[" + thread.getName() + "] " +
							from + " ==> " + to + ": " + content);
				}
			});
		}

		// 사무소 문 닫기 준비 (현재 접수된 일까지만 다 하고 퇴근 지시)
		executorService.shutdown();
	}
}

package ch14.sec09.exam03;

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

public class CallableSubmitExample {
	public static void main(String[] args) {
		// 인력 사무소 오픈: 5명의 직원 고용
		ExecutorService executorService = Executors.newFixedThreadPool(5);

		// 100번의 계산 작업(일거리) 생성 및 접수처에 넣기
		for (int i=1; i<=100; i++) {
			final int idx = i;
			
			// submit()으로 접수: "계산 다 끝나면 결과 보고서(Future) 꼭 제출해!"
			Future<Integer> future = executorService.submit(new Callable<Integer>() {
				@Override
				public Integer call() throws Exception {
					// 5명의 직원 중 누군가가 일을 맡아 덧셈을 수행함
					int sum = 0;
					for (int i=1; i<=idx; i++) {
						sum += i;
					}
					Thread thread = Thread.currentThread();
					System.out.println("[" + thread.getName() + "] 1~" + idx + " 합 계산");
					
					// 일 끝남! 결과물을 반환함
					return sum;
				}
			});

			try {
				// future.get() : "저기요, 아까 받은 교환권 줄 테니까 결과 보고서 주세요!"
				// 직원이 계산을 끝낼 때까지 메인 스레드는 잠시 기다림(블로킹)
				int result = future.get(); 
				System.out.println("\t리턴값: " + result);
			} catch (Exception e) {
				e.printStackTrace();
			}
		}

		// 사무소 문 닫기 (현재 접수된 일까지만 다 하고 퇴근)
		executorService.shutdown();
	}
}