为何调用CompletableFuture.cancel(true)无法中断底层任务？

示例代码 #

public static void main(String[] args) throws Exception {
    ExecutorService executorService = Executors.newCachedThreadPool();
    CompletableFuture<Void> callbackHook = new CompletableFuture<>();
    CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
        try {
            System.out.println("Starting Runnable");
            while (true) {
                System.out.println("still running");
                Thread.sleep(1000);
            }
        } catch (InterruptedException e) {
            // why is this code never getting hit?
            System.err.println("InterruptedException caught in Runnable!");
            callbackHook.complete(null);
        }
    }, executorService);
    future.cancel(true);
    callbackHook.get(); // this hangs forever...
    System.out.println("*** DONE ***"); // this line is never reached
}

输出结果 #

Starting Runnable
still running
still running
still running
still running
...(this continues forever)

核心原因 #

CompletableFuture的cancel(true)和传统Future（如FutureTask）的取消逻辑存在本质区别：

• 传统Future的cancel(true)会主动尝试中断执行任务的线程，因为它持有任务执行线程的引用，可以直接调用Thread.interrupt()。
• 但CompletableFuture的设计定位是异步任务组合工具，它本身并不跟踪执行任务的线程。调用cancel(true)仅会将该Future标记为"已取消"状态，触发后续依赖该Future的回调逻辑（比如whenComplete中的取消分支），但不会主动去中断正在运行的任务线程。

在示例中，任务被提交给ExecutorService执行，CompletableFuture仅负责接收任务的最终状态，无法获取到执行该Runnable的线程实例，自然无法触发中断，所以任务会一直运行下去，InterruptedException永远不会被捕获。

解决方案 #

如果需要中断CompletableFuture对应的底层任务，有两种常见方式：

1. 手动跟踪任务线程：在任务执行时记录当前线程，后续手动调用interrupt()

public static void main(String[] args) throws Exception {
    ExecutorService executorService = Executors.newCachedThreadPool();
    CompletableFuture<Void> callbackHook = new CompletableFuture<>();
    AtomicReference<Thread> taskThread = new AtomicReference<>();
    
    CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
        taskThread.set(Thread.currentThread());
        try {
            System.out.println("Starting Runnable");
            while (!Thread.currentThread().isInterrupted()) {
                System.out.println("still running");
                Thread.sleep(1000);
            }
        } catch (InterruptedException e) {
            System.err.println("InterruptedException caught in Runnable!");
            callbackHook.complete(null);
        }
    }, executorService);
    
    // 等待线程引用被初始化后再中断
    while (taskThread.get() == null) {
        Thread.sleep(100);
    }
    taskThread.get().interrupt();
    
    callbackHook.get();
    System.out.println("*** DONE ***");
    executorService.shutdown();
}

2. 改用ExecutorService返回的Future：ExecutorService.submit()返回的Future实例（本质是FutureTask）支持真正的线程中断

public static void main(String[] args) throws Exception {
    ExecutorService executorService = Executors.newCachedThreadPool();
    CompletableFuture<Void> callbackHook = new CompletableFuture<>();
    
    Future<?> future = executorService.submit(() -> {
        try {
            System.out.println("Starting Runnable");
            while (true) {
                System.out.println("still running");
                Thread.sleep(1000);
            }
        } catch (InterruptedException e) {
            System.err.println("InterruptedException caught in Runnable!");
            callbackHook.complete(null);
        }
    });
    
    future.cancel(true);
    callbackHook.get();
    System.out.println("*** DONE ***");
    executorService.shutdown();
}

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