如何取消CompletableFuture并中断工作线程？该行为是否有文档？

1. 如何取消CompletableFuture同时中断对应工作线程？ #

CompletableFuture的默认cancel(true)和orTimeout方法不会主动中断执行任务的线程，因为它的设计不直接绑定执行线程。要实现取消时中断线程，需要手动关联任务与线程，或者结合ExecutorService返回的原生Future来实现，以下是两种可行方案：

方案一：跟踪任务执行线程 #

自定义可跟踪线程的任务，在任务启动时保存当前线程引用，取消CompletableFuture时主动中断该线程：

// 初始化守护线程池
ExecutorService executor = Executors.newFixedThreadPool(2, r -> {
    Thread t = new Thread(r);
    t.setDaemon(true);
    return t;
});

// 自定义可跟踪线程的任务
class TrackedLongTask implements Runnable {
    private Thread taskThread;

    @Override
    public void run() {
        taskThread = Thread.currentThread();
        try {
            Thread.sleep(10000); // 模拟10秒的长期任务
            System.out.println("Task completed normally.");
        } catch (InterruptedException e) {
            System.out.println("Task cancelled.");
            Thread.currentThread().interrupt(); // 保留中断状态
        }
    }

    public Thread getTaskThread() {
        return taskThread;
    }
}

// 使用示例
TrackedLongTask task = new TrackedLongTask();
CompletableFuture<Void> cf = CompletableFuture.runAsync(task, executor);

// 5秒后触发取消与中断
Executors.newSingleThreadScheduledExecutor().schedule(() -> {
    cf.cancel(true);
    Thread runningThread = task.getTaskThread();
    if (runningThread != null && runningThread.isAlive()) {
        runningThread.interrupt();
    }
}, 5, TimeUnit.SECONDS);

方案二：结合ExecutorService的原生Future #

利用ExecutorService.submit()返回的Future可以中断线程的特性，将其与CompletableFuture关联，取消时同时操作两个Future：

ExecutorService executor = Executors.newFixedThreadPool(2, r -> {
    Thread t = new Thread(r);
    t.setDaemon(true);
    return t;
});

// 定义长期任务
Runnable longTask = () -> {
    try {
        Thread.sleep(10000);
        System.out.println("Task completed normally.");
    } catch (InterruptedException e) {
        System.out.println("Task cancelled.");
        Thread.currentThread().interrupt();
    }
};

// 提交任务获取原生Future，再包装为CompletableFuture
Future<?> nativeFuture = executor.submit(longTask);
CompletableFuture<Void> cf = CompletableFuture.runAsync(() -> {
    try {
        nativeFuture.get();
    } catch (InterruptedException | ExecutionException e) {
        // 处理异常，保留中断状态
        if (e instanceof InterruptedException) {
            Thread.currentThread().interrupt();
        }
    }
}, executor);

// 5秒后取消：先标记CompletableFuture为取消，再中断任务线程
Executors.newSingleThreadScheduledExecutor().schedule(() -> {
    cf.cancel(true);
    nativeFuture.cancel(true); // 此调用会中断执行任务的线程
}, 5, TimeUnit.SECONDS);

2. 该行为是否有官方文档说明？ #

是的，Java官方文档明确说明了CompletableFuture的这种行为：

• CompletableFuture.cancel(boolean mayInterruptIfRunning)：

  此方法会将CompletableFuture标记为已取消，并以CancellationException异常完成，但不会中断执行任务的线程。仅当任务本身在执行过程中检查中断状态时，才会提前终止。

• CompletableFuture.orTimeout(long timeout, TimeUnit unit)：

  如果在指定超时前未完成，此方法会以TimeoutException异常完成CompletableFuture，但同样不会中断执行任务的线程。

这种设计是因为CompletableFuture支持多种执行场景（比如非线程池的异步任务、ForkJoinPool等），无法保证所有任务都能响应中断，因此将线程中断的控制权交给开发者手动处理。

内容的提问来源于stack exchange，提问作者Андрей Щеглов