我有期货清单,在完成每个未来时,我有一个应该执行的回调。番石榴期货等待回调
我正在使用Futures.successfulAsList检查是否所有期货都已完成。但是,这并没有考虑到回调的完成。
有没有一种方法可以确保回调完成?
而不是回调,我可以使用Futures.transform包装到另一个未来并检查完成。但是,有了这个,我无法访问在包装未来中抛出的运行时异常。
ListeningExecutorService service = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(20));
List<ListenableFuture<Object>> futures = new ArrayList<>();
for (int i = 1; i <= 20; i++) {
final int x = i * 100;
ListenableFuture<Object> future = service.submit(new Callable() {
@Override
public Object call() throws Exception {
Thread.sleep(10000/x);
return x;
}
});
futures.add(future);
Futures.addCallback(future, new FutureCallback<Object>() {
@Override
public void onFailure(Throwable t) {
t.printStackTrace();
}
@Override
public void onSuccess(Object x) {
try {Thread.sleep((Integer) x * 10);} catch (Exception e) {}
System.out.println(x);
}
});
}
ListenableFuture<List<Object>> listFuture = Futures
.successfulAsList(futures);
System.out.println("Waiting...");
System.out.println(listFuture.get());
System.out.println("Done");
这是一个真正伟大的问题,因为它在我看来,它可能是不直接由番石榴API支持的一个相当常见的情况。 –