CompletableFuture使用困惑：如何在外部线程中取消并等待其完成

我太懂这种绕晕的感觉了！用CompletableFuture跨线程搞取消+等待完成，尤其是还嵌套了线程阻塞的场景，确实容易踩坑。先帮你理清楚核心问题，再给你落地的解决方案。

首先得敲黑板说个关键细节：CompletableFuture的cancel(true)不会自动中断正在跑的异步任务线程，它只是给Future打个"已取消"的标记，真要让任务停下来、线程中断，得我们自己配合处理。而且你原代码里其实有两层Future：一个是supplyAsync返回的CompletableFuture，另一个是service.submit()返回的普通Future，这俩都得照顾到才能实现需求。

先给原代码补个线程安全的变量定义 #

你原代码里的future是在ExecutorService的线程里赋值的，跨线程访问容易有可见性问题，先把变量改成线程安全的：

private volatile CompletableFuture<String> future;
private volatile Future<?> serviceTaskFuture; // 存submit返回的Future，用来中断执行get()的线程

外部线程的取消+等待逻辑（直接能用） #

在你要执行取消的外部线程里，按这个步骤来写：

public void cancelAndWaitForCompletion() {
    // 1. 先中断ExecutorService里执行future.get()的线程
    if (serviceTaskFuture != null) {
        // 传true表示中断目标线程
        serviceTaskFuture.cancel(true);
    }

    // 2. 标记CompletableFuture为取消状态
    if (future != null) {
        future.cancel(true);
    }

    // 3. 等待CompletableFuture彻底完成（不管是取消、正常完成还是异常完成）
    if (future != null) {
        try {
            future.join();
        } catch (CompletionException e) {
            // 这里捕获到取消触发的异常属于正常流程，不用慌
            System.out.println("CompletableFuture已完成取消: " + e.getCause().getMessage());
        }
    }

    // 4. 收尾：关闭线程池避免资源泄漏
    service.shutdown();
    try {
        // 给5秒等线程池优雅关闭，超时就强制终止
        if (!service.awaitTermination(5, TimeUnit.SECONDS)) {
            service.shutdownNow();
        }
    } catch (InterruptedException e) {
        // 把中断状态传递给当前线程
        Thread.currentThread().interrupt();
        service.shutdownNow();
    }
}

给你拆解每一步的作用，免得你再踩坑 #

• 中断serviceTaskFuture：你原代码里ExecutorService的线程一直在卡着future.get()，这个线程被中断后，future.get()会直接抛出InterruptedException，进入catch块执行future.completeExceptionally(e)，直接把CompletableFuture标记为异常完成状态。
• 调用future.cancel(true)：这是双重保障，哪怕上面的中断没触发（比如线程还没走到future.get()那步），也能让CompletableFuture直接进入取消状态，后续的join()能立刻感知到。
• future.join()：这就是你要的"等待直到完成"，它会阻塞当前外部线程，直到CompletableFuture进入完成/取消/异常状态，而且它不会抛出受检异常，比get()用起来省心多了。
• 关闭线程池：这是必做的收尾，不然ExecutorService的后台线程会一直挂着，导致程序没法正常退出。

额外提一句：你的parkNanos是能响应中断的 #

你用了LockSupport.parkNanos，这个方法会在当前线程被中断时立刻返回，所以supplyAsync里的任务会提前结束，不用额外加中断处理逻辑。要是换成其他不响应中断的阻塞操作（比如某些IO阻塞），那你可能得加个volatile的取消标记，在任务里循环检查这个标记来提前终止。

备注：内容来源于stack exchange，提问作者Eugene