ExecutorService 인터페이스

java.util.concurrent.ExecutorService 인터페이스는 Executor 인터페이스의 하위 인터페이스이며 개별 작업 및 실행기 자체의 수명주기를 관리하는 기능을 추가합니다.

ExecutorService 메서드

Sr. 아니.	방법 및 설명
1	boolean awaitTermination(long timeout, TimeUnit unit) 종료 요청 후 모든 작업이 실행을 완료하거나 시간 초과가 발생하거나 현재 스레드가 중단 될 때까지 차단됩니다.
2	<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) 주어진 작업을 실행하고 모든 완료시 상태와 결과를 보유한 Future 목록을 반환합니다.
삼	<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) 주어진 작업을 실행하고 모든 완료 또는 제한 시간이 만료 될 때 상태 및 결과를 보유한 Future 목록을 반환합니다.
4	<T> T invokeAny(Collection<? extends Callable<T>> tasks) 주어진 작업을 실행하고 성공적으로 완료된 작업의 결과를 반환합니다 (예 : 예외 발생없이).
5	<T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) 주어진 시간 초과가 경과하기 전에 수행 한 작업이 있으면 지정된 작업을 실행하여 성공적으로 완료된 (예 : 예외를 발생시키지 않고) 결과를 반환합니다.
6	boolean isShutdown() 이 실행 프로그램이 종료 된 경우 true를 반환합니다.
7	boolean isTerminated() 종료 후 모든 작업이 완료되면 true를 반환합니다.
8	void shutdown() 이전에 제출 한 작업이 실행되지만 새 작업은 수락되지 않는 순서대로 종료를 시작합니다.
9	List<Runnable> shutdownNow() 현재 실행중인 모든 작업을 중지하려고 시도하고 대기중인 작업의 처리를 중지하며 실행을 기다리고 있던 작업 목록을 반환합니다.
10	<T> Future<T> submit(Callable<T> task) 실행을 위해 값을 반환하는 작업을 제출하고 작업의 보류중인 결과를 나타내는 Future를 반환합니다.
11	Future<?> submit(Runnable task) 실행을 위해 실행 가능한 작업을 제출하고 해당 작업을 나타내는 Future를 반환합니다.
12	<T> Future<T> submit(Runnable task, T result) 실행을 위해 실행 가능한 작업을 제출하고 해당 작업을 나타내는 Future를 반환합니다.

예

다음 TestThread 프로그램은 스레드 기반 환경에서 ExecutorService 인터페이스의 사용법을 보여줍니다.

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

public class TestThread {

   public static void main(final String[] arguments) throws InterruptedException {
      ExecutorService executor = Executors.newSingleThreadExecutor();

      try {
         executor.submit(new Task());
         System.out.println("Shutdown executor");
         executor.shutdown();
         executor.awaitTermination(5, TimeUnit.SECONDS);
      } catch (InterruptedException e) {
         System.err.println("tasks interrupted");
      } finally {

         if (!executor.isTerminated()) {
            System.err.println("cancel non-finished tasks");
         }
         executor.shutdownNow();
         System.out.println("shutdown finished");
      }
   }

   static class Task implements Runnable {
      
      public void run() {
         
         try {
            Long duration = (long) (Math.random() * 20);
            System.out.println("Running Task!");
            TimeUnit.SECONDS.sleep(duration);
         } catch (InterruptedException e) {
            e.printStackTrace();
         }
      }
   }	   
}

그러면 다음과 같은 결과가 생성됩니다.

산출

Shutdown executor
Running Task!
shutdown finished
cancel non-finished tasks
java.lang.InterruptedException: sleep interrupted
	at java.lang.Thread.sleep(Native Method)
	at java.lang.Thread.sleep(Thread.java:302)
	at java.util.concurrent.TimeUnit.sleep(TimeUnit.java:328)
	at TestThread$Task.run(TestThread.java:39)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)