ExecutorService如何取消任务

在 Java 中，ExecutorService 本身不能直接“取消线程”，而是通过 Future 来取消已提交的任务。下面按常见场景系统说明。

一、基本方式：使用 Future.cancel()

1. 提交任务并拿到 Future

ExecutorService executor = Executors.newFixedThreadPool(2);

Future<?> future = executor.submit(() -> {
    while (true) {
        // 模拟长时间任务
        Thread.sleep(1000);
    }
});

2. 取消任务

boolean canceled = future.cancel(true);

cancel(boolean mayInterruptIfRunning) 参数说明

• true：如果任务正在运行，尝试中断线程
• false：如果任务正在运行，不中断，等它自己结束

⚠️ cancel(true) 只是设置中断标志，是否真能停止，取决于任务代码

二、任务如何“响应取消”

关键：任务必须检查中断状态

正确写法 ✅

executor.submit(() -> {
    while (!Thread.currentThread().isInterrupted()) {
        // 做点事
    }
    System.out.println("任务被取消");
});

或：

try {
    Thread.sleep(1000);
} catch (InterruptedException e) {
    Thread.currentThread().interrupt(); // 恢复中断状态
    return;
}

错误写法 ❌（无法取消）

while (true) {
    // 不检查中断
}

三、不同任务的取消行为

1. Runnable（无返回值）

Future<?> f = executor.submit(runnable);
f.cancel(true);

2. Callable（有返回值）

Future<String> f = executor.submit(callable);
f.cancel(true);

四、关闭整个 ExecutorService

1. 优雅关闭（等任务完成）

executor.shutdown();

2. 立即关闭（尝试中断所有任务）

List<Runnable> remaining = executor.shutdownNow();

shutdownNow() 内部也是调用任务的 interrupt()

五、常见坑总结 ⚠️

六、示例：可取消的任务模板

executor.submit(() -> {
    try {
        while (!Thread.currentThread().isInterrupted()) {
            // 业务逻辑
        }
    } finally {
        // 清理资源
    }
});

如果你有 具体场景（如定时任务、HTTP 请求、数据库查询、Spring 中用法），我可以给你更针对性的方案。