완료되면 다시 전화 :FutureCallback 내 ListenableFuture를 시작하고 모든 내가 ListenableFutures에 대한 콜백의 중첩 레이어, 이런 일이하기 위해 노력하고있어
ListeningExecutorService service = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(10));
ListenableFuture<A> futureA = service.submit(() -> a.doSomething());
Futures.addCallback(futureA, new FutureCallback<A>() {
@Override
public void onSuccess(A result) {
ListenableFuture<B> futureB = service.submit(() -> b.doSomething(result)
}
});
을 어떻게 콜백을 추가 할 때 모두 futureA
및 futureB
완전한?
이것은 간단한 예이지만 ListenableFuture
의 여러 계층을 포함 할 수있는 솔루션을 찾고 있습니다.
'allAsList'를? http://docs.guava-libraries.googlecode.com/git/javadoc/com/google/common/util/concurrent/Futures.html#allAsList (com.google.common.util.concurrent.ListenableFuture ...) –