如何取消Spring框架中@Async注解启动的正在运行的异步任务

首先明确：Spring 中@Async标记的方法本质是提交到线程池执行的工作任务，Java没有强制杀死运行中线程的安全方式，线程中断是协作式机制，要完成任务终止必须两部分配合：

• 调用方持有任务的执行句柄，触发取消信号
• 任务自身的业务逻辑主动感知中断信号，完成资源清理后退出

第一步：改造异步方法，返回任务句柄并支持中断响应 #

你当前用void作为异步方法返回值的写法，调用方拿不到任务的引用，根本无法触发取消操作。需要将返回值改为Spring原生支持的CompletableFuture，同时在业务逻辑里处理中断信号：

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import java.util.concurrent.CompletableFuture;

@Service
public class AsyncJobService {

    @Async("asyncExecutor")
    public CompletableFuture<Void> executeJob(String jobBizId) {
        try {
            // 循环执行业务逻辑时，主动检查当前线程的中断标记
            while (!Thread.currentThread().isInterrupted()) {
                // 替换为你的实际业务逻辑，比如数据扫描、批量处理
                System.out.printf("业务任务[%s]正在执行%n", jobBizId);
                
                // 阻塞类操作（Thread.sleep、IO等待、锁等待等）会自动响应中断，抛出InterruptedException
                Thread.sleep(1000);
            }
        } catch (InterruptedException e) {
            // 捕获到中断异常说明收到取消信号，在这里做资源清理：关闭文件流、回滚中间状态、断开连接等
            System.out.printf("业务任务[%s]收到取消信号，开始清理资源%n", jobBizId);
            // 必须恢复中断标记，避免上层逻辑丢失中断状态
            Thread.currentThread().interrupt();
        } finally {
            System.out.printf("业务任务[%s]已终止%n", jobBizId);
        }
        return CompletableFuture.completedFuture(null);
    }
}

改造注意点 #

• 不要吞掉InterruptedException不做任何处理，否则任务永远无法响应取消
• 如果是纯CPU计算型逻辑、没有阻塞操作，必须主动通过Thread.currentThread().isInterrupted()判断中断状态，否则感知不到取消信号
• 你现有的ThreadPoolTaskExecutor线程池配置不需要做额外修改即可支持该逻辑

第二步：持有任务句柄，触发取消操作 #

调用异步方法时会拿到对应的CompletableFuture句柄，你可以根据业务维度（比如业务任务ID）缓存这些句柄，需要终止时调用cancel方法即可：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.Map;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ConcurrentHashMap;

@Component
public class JobManager {

    @Autowired
    private AsyncJobService asyncJobService;

    // 线程安全的缓存，存储运行中任务的句柄，key为自定义的业务任务ID
    private final Map<String, CompletableFuture<Void>> runningTaskMap = new ConcurrentHashMap<>();

    // 启动任务示例
    public void startJob(String jobBizId) {
        CompletableFuture<Void> taskFuture = asyncJobService.executeJob(jobBizId);
        runningTaskMap.put(jobBizId, taskFuture);
        // 任务无论正常结束、异常退出还是被取消，都自动从缓存中移除句柄，避免内存泄漏
        taskFuture.whenComplete((result, throwable) -> runningTaskMap.remove(jobBizId));
    }

    // 取消任务示例
    public boolean cancelRunningJob(String jobBizId) {
        CompletableFuture<Void> taskFuture = runningTaskMap.get(jobBizId);
        if (taskFuture == null) {
            return false;
        }
        // cancel参数说明：
        // 传true：如果任务正在运行，给执行线程发送中断信号，尝试终止运行中的任务
        // 传false：仅当任务还在队列中未开始执行时移除任务，不中断正在运行的任务
        boolean cancelSuccess = taskFuture.cancel(true);
        runningTaskMap.remove(jobBizId);
        return cancelSuccess;
    }
}

额外说明 #

• 不要使用Thread.stop()这类已废弃的强杀线程方法，会导致锁资源不释放、数据状态不一致等严重问题，所有任务终止逻辑都必须走协作式中断。
• 如果业务逻辑中调用的第三方客户端不响应中断，无法通过上述方式终止，需要在第三方调用层面配置超时时间，避免任务永久卡死。
• 如果需要服务停机时优雅关闭线程池，可以给线程池补充配置executor.setWaitForTasksToCompleteOnShutdown(true)，设置合理的等待时间，该配置不影响运行中的任务取消逻辑。

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