자바 동시성-선물 및 호출 가능
java.util.concurrent.Callable 객체는 스레드 만 실행할 수있는 실행 가능한 인터페이스와 달리 스레드가 수행 한 계산 결과를 반환 할 수 있습니다. Callable 객체는 스레드에 의해 실행되는 작업의 진행 상황을 모니터링하는 메서드를 제공하는 Future 객체를 반환합니다. Future 객체를 사용하여 Callable의 상태를 확인한 다음 스레드가 완료되면 Callable에서 결과를 검색 할 수 있습니다. 시간 제한 기능도 제공합니다.
통사론
//submit the callable using ThreadExecutor
//and get the result as a Future object
Future<Long> result10 = executor.submit(new FactorialService(10));
//get the result using get method of the Future object
//get method waits till the thread execution and then return the result of the execution.
Long factorial10 = result10.get();
예
다음 TestThread 프로그램은 스레드 기반 환경에서 Future와 Callables의 사용법을 보여줍니다.
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
public class TestThread {
public static void main(final String[] arguments) throws InterruptedException,
ExecutionException {
ExecutorService executor = Executors.newSingleThreadExecutor();
System.out.println("Factorial Service called for 10!");
Future<Long> result10 = executor.submit(new FactorialService(10));
System.out.println("Factorial Service called for 20!");
Future<Long> result20 = executor.submit(new FactorialService(20));
Long factorial10 = result10.get();
System.out.println("10! = " + factorial10);
Long factorial20 = result20.get();
System.out.println("20! = " + factorial20);
executor.shutdown();
}
static class FactorialService implements Callable<Long> {
private int number;
public FactorialService(int number) {
this.number = number;
}
@Override
public Long call() throws Exception {
return factorial();
}
private Long factorial() throws InterruptedException {
long result = 1;
while (number != 0) {
result = number * result;
number--;
Thread.sleep(100);
}
return result;
}
}
}
그러면 다음과 같은 결과가 생성됩니다.
산출
Factorial Service called for 10!
Factorial Service called for 20!
10! = 3628800
20! = 2432902008176640000