Futures.addCallback 如何保证回调在执行未来任务的线程上执行

Question

代码如下所示：

final ListeningExecutorService executor = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(4));
final Callable<String> asyncTask = new Callable<String>() {
    @Override
    public String call() throws Exception {
    return TestFuture.computeResult();
    }
};
final int listSize = 10;
final List<ListenableFuture<String>> listenableFutures = Lists.newArrayListWithExpectedSize(listSize);
for (int i = 0; i < listSize; i++) {
    listenableFutures.add(executor.submit(asyncTask));
}
for (final ListenableFuture<String> listenableFuture2 : listenableFutures) {
    Futures.addCallback(listenableFuture2, new FutureCallback<String>() {
    @Override
    public void onSuccess(final String result) {
        System.out.println("callback success with " + result + " at " + Thread.currentThread().getName());
    }
    @Override
    public void onFailure(final Throwable thrown) {
        System.out.println("callback failed with " + thrown.getMessage());
    }
    });
}

我无法弄清楚如何在将执行asyncTask的线程上计划执行回调？

我可以看到Futures.addCallback调用addCallback(future, callback, MoreExecutors.sameThreadExecutor());，但我不知道MoreExecutors.sameThreadExecutor如何保证这一点？

Answer 1

sameThreadExecutor()只是执行传递给其内联execute(Runnable)方法的任何Runnable：也就是说，它只是调用run()。它根本不做任何与线程相关的操作。并且，回调Runnable将传递给执行asyncTask的同一线程上的关联Executor，因为ListeningExecutorService有效地将asyncTask包装在调用其done()方法时调用所有回调的FutureTask中。

注意：实际上并不能保证所有回调都将在执行asyncTask的线程上执行。例如，如果在asyncTask完成后添加回调，它将在添加回调的线程上执行(假设除了sameThreadExecutor()之外没有提供供回调使用的Executor(。