1. Executors의 역할

2. 주요 Interface

3. Single Thread

4. 원하는 Thread Pool 개수로 제한하기

5. ScheduleExecutorService

1. Executors의 역할

Thread 만들기 : Application이 사용할 Thread Pool을 만들어서 관리함.

Thread 관리 : Thread의 생명 주기를 관리 함.

작업 처리 및 실행 : Thread로 실행할 작업을 제공할 수 있는 API를 제공함.

2. 주요 Interface

• Executors

  →Execute(Runnable(Click)) : 딱 하나의 메소드만 존재.

• ExecutorService(Click)

  → Executors를 상속받은 인터페이스로, Callable(Click)도 실행할 수 있으며

  → Executors를 종료 시키거나 여러 Callable을 동시에 실행하는 등의 기능을 제공함.

3. Single Thread

//싱글스레드 사용
ExecutorService executorService = Executors.newSingleThreadExecutor();
//사용방법 1 : execute(new Runnable()) 고전적인 방법
executorService.execute(new Runnable() {
    @Override
    public void run() {
        System.out.println("1. Thread "+Thread.currentThread().getName());
    }
});

//사용방법 2 : submit()
executorService.submit(()-> {
    System.out.println("2. Thread "+Thread.currentThread().getName());
});

/*
executorService는 작업을 실행하고나면 다음 작업이 들어올때까지 계속해서 대기하므로 
프로세스가 종료되지 않는다 -> 따라서 명시적으로 프로세스를 종료해줘야 한다
shutdown() _ gracefull하다 즉, 하고있는 일을 마무리하고 종료
shutdownNow() _ noMercy하다, 일의 마무리를 보장하지 않고 그냥 종료
 */
 
executorService.shutdown();

4. 원하는 Thread Pool 개수로 제한하기

//2개의 쓰레드를 고정쓰레드 개수로 사용하겠다
ExecutorService executorService = Executors.newFixedThreadPool(2);
executorService.submit(getRunnable("Hello"));
executorService.submit(getRunnable("woonsik"));
executorService.submit(getRunnable("the"));
executorService.submit(getRunnable("java"));
executorService.submit(getRunnable("Thread"));

executorService.shutdown();

private static Runnable getRunnable(String string) {
	return ()-> System.out.println(string + Thread.currentThread().getName());
}

/*
어떻게 2개의 쓰레드로 5개의 작업을 수행?

메인에서 executor service에 5개의 작업을 보낸다
-> Thread pool에는 2개의 쓰레드만 존재 && Blocking Queue가 존재
-> 쓰레드가 바쁘면 나머지는 blocking queue에서 기다리고있다가 수행이 된다

5. ScheduleExecutorService

→ ExecutorService를 상속받은 인터페이스로 특정 시간 이후

→ 또는 주기적으로 작업을 실행할 수 있음.

System.out.println("싱글쓰레드 쓰케쥴executors");
ScheduledExecutorService executorService = 
	Executors.newSingleThreadScheduledExecutor();

//3초 대기 후 출력 (Runnable command, long delay, TimeUnit unit) <- 매개변수
executorService.schedule(getRunnable("Hello"), 3, TimeUnit.SECONDS);
executorService.shutdown();

//특정 시간마다 반복 - 1초기다렸다가 2초마다 반복 (command, initial delay, 
		period, TimeUnit unit)
executorService.scheduleAtFixedRate(getRunnable("hello"), 
		1, 2, TimeUnit.SECONDS);