FutureTask의 연산은 Callable 인터페이스를 구현하도록 되어있다.

• 대기 / 시작됨 / 종료됨의 상태를 갖을 수 있다.
• 종료상태에는 정상종료 / 취소 / 예외발생 등을 알수 있다.
• 한번 종료 상태에 이르고나면 더이상 상태가 바뀌는 일은 없다.

FutureTask.get

• 종료상태에 이르지 않았다면 종료될때 까지 블러킹
• 종료되었다면 작업결과를 반환하거나 오류가 발생하였을 경우 예외를 던져준다.

예제

public class FutureTaskTest {
    public static void main(String[] args) throws InterruptedException, ExecutionException {
        // 어떤 비동기작업이라 가정하고
        FutureTask<String> task1 = new FutureTask<>(() -> "Task1");
        FutureTask<String> task2 = new FutureTask<>(() -> { throw new RuntimeException("Error!"); });
  
        new Thread(task1).start();
        new Thread(task2).start();
 
        // FutureTask.get() 은 작업이 완료될때까지 블러킹됨 (물론 여기서는 바로 돌려주겠지만..)
        System.out.println(task1.get());
        System.out.println(task2.get());
    }
}

결과는 다음과 같다.

• 예외 발생시에는 ExecutionException 예외로 wrapping 된 형태로 돌려준다.
• ExecutionException.getCause() 메서드로 한번 더 까봐야하는 불편함이 있다..

Task1
Exception in thread "main" java.util.concurrent.ExecutionException: java.lang.RuntimeException: Error!
    at java.util.concurrent.FutureTask.report(FutureTask.java:122)
    at java.util.concurrent.FutureTask.get(FutureTask.java:192)
    at test.FutureTaskTest.main(FutureTaskTest.java:17)
Caused by: java.lang.RuntimeException: Error!
    at test.FutureTaskTest.lambda$1(FutureTaskTest.java:11)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.lang.Thread.run(Thread.java:745)