Java 虚拟线程执行器的生命周期管理

Java 虚拟线程执行器的关键不是“线程轻量，所以可以不管生命周期”，而是要把执行器当成一个明确的任务边界：在边界内提交任务、收集结果，在边界结束时关闭执行器；如果只需要停止某一项任务，则保留它对应的 Future 并调用取消。这样可以把正常收尾、超时收敛和单任务取消分开处理。

官方文档：https://docs.oracle.com/en/java/javase/26/

下面用一个“批量生成报告摘要”的小项目串起这几个动作。示例只展示生命周期设计，不把图片或文字当作真实运行截图。

项目目标：让一次批量任务有清晰的归属

假设程序收到一组报告编号，需要并发生成摘要。Executors.newVirtualThreadPerTaskExecutor() 会为每个任务创建一个虚拟线程，返回的仍然是 ExecutorService。它适合把大量短生命周期任务放在同一个作用域里管理，但不会替我们决定什么时候结束这个作用域。

因此，小项目的验收目标很具体：所有提交动作发生在同一个执行器内；正常路径能回收每个 Future 的结果；提前退出时能取消未完成任务；执行器最终一定进入关闭状态。

把虚拟线程执行器封装成可关闭的任务边界

先把创建、提交和结果回收放进一个方法。这里使用 try-with-resources，是因为 ExecutorService 实现了 AutoCloseable；离开代码块时会执行有序关闭并等待已经提交的任务完成。

import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public final class ReportRunner {
    private ReportRunner() {
    }

    public static List run(Collection reportIds)
            throws InterruptedException, ExecutionException {
        // 一个方法调用对应一个执行器边界，避免把生命周期藏在全局变量里。
        try (ExecutorService executor = Executors.newVirtualThreadPerTaskExecutor()) {
            List> futures = new ArrayList(reportIds.size());
            for (String reportId : reportIds) {
                // Future 既保存结果，也为后续的单任务取消留下句柄。
                futures.add(executor.submit(() -> buildSummary(reportId)));
            }

            List summaries = new ArrayList(futures.size());
            for (Future future : futures) {
                // get 会等待对应任务完成，并把任务异常传回调用方。
                summaries.add(future.get());
            }
            return summaries;
        }
    }

    private static String buildSummary(String reportId) {
        // 示例用纯内存结果代替外部服务，重点是执行器与 Future 的关系。
        return "summary:" + reportId;
    }
}

这个结构里最容易忽略的是“执行器不等于结果集合”。执行器负责接收任务并安排执行，Future 负责代表某一次提交的结果；把两者都保存在方法作用域里，才能在异常或提前退出时找到对应的控制点。

关闭与取消要分成两条控制线

close() 和 shutdown() 解决的是执行器级别的生命周期：不再接受新任务，并让已经提交的任务有机会完成。Future.cancel(true) 解决的是单个任务的取消：尚未开始的任务不会运行，已经开始的任务通常会收到中断请求，但任务本身必须配合中断才能尽快退出。

import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;

public final class ExecutorLifecycle {
    private ExecutorLifecycle() {
    }

    public static void cancelPending(List extends Future>> futures) {
        for (Future> future : futures) {
            // true 表示允许实现在线程已运行时尝试发出中断请求。
            if (!future.isDone()) {
                future.cancel(true);
            }
        }
    }

    public static void shutdownGracefully(ExecutorService executor)
            throws InterruptedException {
        // 先拒绝新任务，给已提交任务一个正常结束窗口。
        executor.shutdown();
        if (!executor.awaitTermination(2, TimeUnit.SECONDS)) {
            // 超时只说明仍未结束，不能把它当成任务已被强制停止。
            executor.shutdownNow();
            if (!executor.awaitTermination(2, TimeUnit.SECONDS)) {
                throw new IllegalStateException("executor did not terminate");
            }
        }
    }
}

生产代码还要处理关闭线程自身被中断的情况：捕获 InterruptedException 后调用 shutdownNow()，再用 Thread.currentThread().interrupt() 恢复当前线程的中断标记。不要只依赖 shutdownNow() 的名字判断结果，它只是尽力停止运行中的任务，并不会保证一个忽略中断的任务立即结束。

用一个生命周期清单验收小项目

可以按下面的顺序检查设计，而不需要把虚拟线程当作一个需要手动回收的线程池：

1. 创建点是否靠近任务作用域，是否避免把执行器泄露为无主的全局对象。
2. 正常路径是否调用 close() 或 shutdown()，并在需要时调用 awaitTermination()。
3. 是否保存了需要被单独取消的任务对应的 Future。
4. 任务内部是否检查中断、处理 InterruptedException，并在退出前释放自己的资源。
5. 超时后是否记录仍未完成的任务，而不是把 shutdownNow() 当成成功证明。

如果只是一次性批量操作，try-with-resources 通常是最易读的边界；如果执行器由更长生命周期的服务持有，则把关闭动作放进服务的停止钩子，并用两阶段关闭策略收敛。无论选哪一种，核心都是让“执行器关闭”和“任务取消”分别有可追踪的代码入口。

常见问题

虚拟线程执行器需要像固定线程池一样设置线程数量吗？

newVirtualThreadPerTaskExecutor() 的语义是每个任务创建一个虚拟线程，不应把它理解成传统意义上的固定大小线程池。真正需要限制的是外部资源的并发度，例如数据库连接、下游服务配额或文件句柄，这些限制应通过信号量、连接池或服务端流控表达。

调用 Future.cancel(true) 后任务一定停止吗？

不一定。它对未开始的任务可以抑制执行；对已开始的任务通常是发出中断请求。任务如果吞掉中断、长时间执行不可中断的操作，仍可能继续运行，所以取消接口必须和任务内部的中断响应约定一起设计。

什么时候选择 close，什么时候手动 shutdown？

作用域短、任务提交集中时优先使用 try-with-resources 和 close()；需要超时、分阶段等待、记录未结束任务或在服务停止时统一处理时，使用 shutdown()、awaitTermination() 和必要的 shutdownNow() 组合更合适。

总结

Java 虚拟线程执行器的生命周期可以归纳为三件事：用 ExecutorService 承担任务边界，用 close() 或两阶段关闭完成执行器收尾，用 Future.cancel(true) 表达单任务取消。把这三条控制线分开，虚拟线程的轻量特性才不会演变成任务悬挂和资源失控。