Callable是否也在线程中执行？JVM执行Callable的机制探究

问题背景 #

当向ExecutorService传入Runnable时：

Future future = executorService.submit(runnable);
// 此时ExecutorService会将该对象转换为FutureTask实例
new FutureTask(runnable);

随后通过addWorker(runnable)执行Runnable，内部由线程完成执行。

而针对Callable的情况：

Future future = executorService.submit(callable);
// 此时ExecutorService同样会将该对象转换为FutureTask实例
new FutureTask(callable);

核心疑问 #

1. JVM是如何映射Callable并使其并发运行的？
2. 它如何利用线程执行Callable，并将Callable方法的返回结果映射到FutureTask实例中？
3. 由于Thread与run()方法绑定紧密，若使用线程执行Callable，JVM是如何调用Callable的call()方法的？

核心原理：FutureTask作为Runnable与Callable的桥梁 #

问题的关键在于**FutureTask同时实现了Runnable和Future接口**，它是连接Thread（仅支持执行Runnable）与Callable的核心适配类。

1. 线程如何执行Callable？

Thread只能执行重写了run()方法的对象，但Callable定义的是call()方法。FutureTask的run()方法内部会主动调用Callable的call()，简化后的JDK核心逻辑如下：

public class FutureTask<V> implements RunnableFuture<V> {
    private Callable<V> callable;
    private Object outcome; // 存储call()的返回结果

    public FutureTask(Callable<V> callable) {
        if (callable == null)
            throw new NullPointerException();
        this.callable = callable;
    }

    public void run() {
        try {
            Callable<V> c = callable;
            if (c != null) {
                V result = c.call(); // 直接调用Callable的call()方法
                set(result); // 将结果存入内部变量
            }
        } catch (Throwable ex) {
            setException(ex); // 捕获异常并存储
        }
    }
}

当ExecutorService通过addWorker把FutureTask交给线程执行时，线程调用的是FutureTask.run()，而这个方法内部直接触发了Callable.call()——完全符合Thread对Runnable的执行逻辑，JVM不需要做额外特殊处理。

2. 返回结果如何映射到FutureTask？

FutureTask内部维护了一个线程安全的outcome变量，专门用来存储call()的返回值（或执行时抛出的异常）。当call()执行完成后，set(result)方法会：

1. 线程安全地将结果赋值给outcome；
2. 唤醒所有通过Future.get()等待结果的线程。

当你调用Future.get()时，FutureTask会检查outcome状态：

• 如果已完成赋值，直接返回结果；
• 如果未完成，当前线程会进入阻塞状态，直到run()执行完成并调用set(result)唤醒它。

3. JVM层面的映射逻辑

JVM不需要为Callable做特殊映射，因为最终执行的还是标准的Runnable实例（FutureTask）。ExecutorService.submit(callable)只是完成了适配包装：把Callable转换成FutureTask（一个合法的Runnable），后续的线程执行流程和普通Runnable完全一致：

Callable → FutureTask（实现Runnable） → Thread执行FutureTask.run() → 内部触发Callable.call() → 结果存入FutureTask → Future.get()获取结果

内容的提问来源于stack exchange，提问作者Adarsh Verma