java - FutureTask的两种用法之间有什么区别？

使用线程池：

ExecutorService exec = Executors.newFixedThreadPool(5);
FutureTask<Integer> ft = new FutureTask<Integer>(() -> rpcMethod());
exec.submit(ft);

调用运行方法：

FutureTask<Integer> ft = new FutureTask<Integer>(() -> rpcMethod());
ft.run()

我查看了run方法的源代码，就好像是一个同步调用一样，似乎没有新线程。
我遇到这个问题的原因是因为我查看了Dubbo的RpcContext＃asyncCall的源代码，发现它直接在使用FutureTask＃run。这是代码的一部分。

public <T> Future<T> asyncCall(Callable<T> callable) {
        try {
            try {
                setAttachment(Constants.ASYNC_KEY, Boolean.TRUE.toString());
                final T o = callable.call();
                //local调用会直接返回结果.
                if (o != null) {
                    FutureTask<T> f = new FutureTask<T>(new Callable<T>() {
                        public T call() throws Exception {
                            return o;
                        }
                    });
                    f.run();
                    return f;
                } else {

                }

最佳答案

FutureTask是Runnable的实现。

区别是

如果您使用exec.submit（ft）;它的异步操作，在两个不同的线程中执行。

如果您使用ft.run（）;它在同一线程中执行。

如有任何疑问，请尝试此操作。我将getResult（）放在另一个方法中，所以您有一个更明确的调用堆栈：

public class FutureExample {

private Callable<Long> call = new Callable<Long>() {

    private Long getResult(){
        return Thread.currentThread().getId();
    }

    @Override
    public Long call() {
        return getResult();
    }
};

private Long callByRun() throws ExecutionException, InterruptedException {
    FutureTask<Long> ft = new FutureTask<>(call);
    ft.run();
    return ft.get();
}

private Long callByExec() throws ExecutionException, InterruptedException {
    ExecutorService pool = Executors.newFixedThreadPool(5);
    FutureTask<Long> ft = new FutureTask<>(call);
    pool.submit(ft);
    Long result = ft.get();
    pool.shutdown();
    return result;
}

public static void main(String[] args) throws ExecutionException, InterruptedException {
    Long mainThreadId = Thread.currentThread().getId();
    System.out.println(String.format("main: %d callByRun %d", mainThreadId, new FutureExample().callByRun()));
    System.out.println(String.format("main: %d callByExec %d", mainThreadId, new FutureExample().callByExec()));
}

}

关于java - FutureTask的两种用法之间有什么区别？，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/58605075/