ExecutorService 와 Future

 ExecutorService 

🔥 자바의 스레드를 편하게 관리하기 위한 라이브러리로 스레드 풀및 스레드 생성 혹은 그 작업을 가능하게 한다.

   newFixedThreadPool(int) 

🖌️ ThreadPool (ThreadPoolExecutor) 생성을 위한 정적 팩터리 메서드중 하나로

     인자 개수만큼 고정된 ThreadPool 을 만든다.

 

// 스레드가 20개로 고정되는 Thread Pool 생성한다.
ExecutorService es = Executors.newFixedThreadPool(20);

 newCachedThreadPool 

🖌️ ThreadPool (ThreadPoolExecutor) 생성을 위한 정적 팩터리 메서드중 하나로 필요할 때, 필요한 만큼 ThreadPool 을 만든다. 이미 생성된 쓰레드를 재사용 해 성능상의 이점이 있을 수 있다.

// Thread Pool 생성
ExecutorService es = Executors.newCachedThreadPool();

 

  newSingleThreadExecutor() 

🖌️ 쓰레드 한 개인 ExecutorService를 생성하는 정적 팩터리 메서드다. 싱글 쓰레드 작업을 처리할 때 사용한다.

 

// 싱글 쓰레드 ExecutorService 를 생성한다.
ExecutorService es = Executors.newSingleThreadExecutor();

 execute(Runnable run) 

👟 새로운 스레드를 통해 Runnable 을 실행한다.

  es.execute(() -> {
      try {
        Thread.sleep(2000);
      } catch (InterruptedException e) {}
      log.info("Async");
    });
    log.info("Exit");
  }

결과

07:49:58.256 [main] INFO asynchronous.toby.FutureEx - Exit
07:50:00.260 [pool-1-thread-1] INFO asynchronous.toby.FutureEx - Async

 submit(Callable task) 

👟 새로운 스레드를 통해 Callable 을 실행하여 그 결과 값을 반환한다. 이 때 반환하는 값을 Future 를 통해 받을 수 있다.

Future<String> future = es.submit(() -> {
      Thread.sleep(2000);
      log.info("Async");
      return "Hello";
});

 Future 

🔥 미래에 실행될 비동기 작업을 통한 결과에 대한 핸들러(Hanlder)

  get() 

👟 Callable 의 작업 결과를 반환하는 메서드. 해당 메서드 실행 시 스레드 실행의 결과 값이 반환 할 때 까지 블로킹(Blocking) 상태를 유지한다.

🤔 매개변수를 통해 Timeout 을 지정하는 방법도 있다.

 

// 작업(Task) 시작 
Future<String> future = es.submit(() -> { 
      Thread.sleep(2000);
      log.info("Async");
      return "Hello";
  });

//Blocking : 결과를 받기 위해 해당 스레드에서 결과 값을 받기 전 까지 블록킹을 하고 있다.
String hello = future.get(); 

System.out.println(hello);
log.info("Exit");

 

 

결과

07:45:20.340 [pool-1-thread-1] INFO asynchronous.toby.FutureEx - Async
Hello
07:45:20.346 [main] INFO asynchronous.toby.FutureEx - Exit

  isDone() 

👟 Callable 의 작업의 현재 상태를 반환하는 메서드이다.
    작업이 완료 되었다면 True 를 아직 작업이 완료되지 않은 상태라면 False 를 반환한다.
    이 메서드는 논 블록킹(Non-Blocking) 으로 작동한다.

 

Future<String> future = es.submit(() -> {
      Thread.sleep(2000);
      log.info("Async");
      return "Hello";
});

System.out.println(future.isDone());
Thread.sleep(2100);
log.info("Exit");
System.out.println(future.get());

 

결과

08:01:03.626 [pool-1-thread-1] INFO asynchronous.toby.FutureEx - Async
true
08:01:07.736 [main] INFO asynchronous.toby.FutureEx - Exit
Hello

  FutureTask 

🔥 Future 와 Callable(비동기 작업) 을 통합한 기본 구현체

  done() 

👟 FutureTask 의 execute(비동기 작업)이 끝날 때 호출되는 Protected 메서드로 결과를 가로채는 후킹(Hooking) 이 가능하다.

FutureTask<String> future = new FutureTask<>(() -> {
      Thread.sleep(2000);
      log.info("Async");
      return "Hello";
     }) {
      // 비동기 작업이 끝날 때 호출되는 메서드로 후킹이 가능하다.
      @Override
      protected void done() {
        try {
          System.out.println(get());
        } catch (Exception e) {
          throw new RuntimeException(e);
        }
        }
        };

    es.execute(future);
    es.shutdown();

 

결과
08:11:31.097 [pool-1-thread-1] INFO asynchronous.toby.FutureEx - Async
Hello

 

참조

• Java - ExecutorService를 사용하는 방법
• 토비의 봄 TV 8회 스프링 리액티브 프로그래밍