<dependency>
     <groupId>org.springframework.boot</groupId>
     <artifactId>spring-boot-starter-actuator</artifactId>
 </dependency

# 開(kāi)發(fā)環(huán)境配置
server:
  # 服務(wù)器的HTTP端口，默認(rèn)為80
  port: 80

management:
  endpoint:
    shutdown:
      enabled: true
  endpoints:
    web:
      exposure:
        include: "shutdown"
      base-path: /monitor

curl -X POST http://localhost:80/monitor/shutdown

package com.angel.ocean.tool.util;

import com.angel.ocean.tool.task.CommonTask;
import lombok.extern.slf4j.Slf4j;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;

/**
 * 異步任務(wù)工具類(lèi)
 */
@Slf4j
public class TaskExecutorUtil {

    // Task運(yùn)行狀態(tài)
    public static volatile boolean isRunning = true;

    // Task運(yùn)行結(jié)果Future集合
    private final static List<Future<?>> runningTasks = new ArrayList<>();

    // 線程池
    static ExecutorService executorPool = new ThreadPoolExecutor(corePoolSize(), maximumPoolSize(), 10, TimeUnit.MINUTES,
            new ArrayBlockingQueue<Runnable>(1000), new ThreadPoolExecutor.CallerRunsPolicy());

    /**
     * Task執(zhí)行
     */
    public static void executeTask(CommonTask task) {
        Future<?> future = executorPool.submit(task);
        runningTasks.add(future);
    }

    /**
     * 關(guān)閉運(yùn)行中所有線程，如果任務(wù)正在執(zhí)行中，待執(zhí)行完成再中斷該線程
     */
    public static void stopAllTasks() {
        isRunning = false;
        for (Future<?> future : runningTasks) {
            try {
                boolean flag = true;
                while (flag) {
                    // 如果任務(wù)還在執(zhí)行中，就休眠100ms
                    if(!future.isDone()) {
                        Thread.sleep(100);
                    } else {
                        flag = false;
                    }
                }
            } catch (InterruptedException e) {
                // 打印異常
                log.error("TaskExecutorUtil stopAllTasks {}", e.getMessage(), e);
            } finally {
                // 中斷任務(wù)
                future.cancel(true);
            }
        }
    }

    /**
     * 關(guān)閉線程池
     */
    public static void waitForTasksToComplete() {
        // 等待所有任務(wù)完成
        executorPool.shutdown();
    }

    /**
     * 核心線程數(shù)
     */
    private static int corePoolSize() {
        return Runtime.getRuntime().availableProcessors();
    }

    /**
     * 最大線程數(shù)
     */
    private static int maximumPoolSize() {
        return Runtime.getRuntime().availableProcessors() * 2;
    }
}

package com.angel.ocean.tool.event;

import com.angel.ocean.tool.util.TaskExecutorUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.ApplicationListener;
import org.springframework.context.event.ContextClosedEvent;
import org.springframework.stereotype.Component;

/**
 *  監(jiān)聽(tīng) Spring 應(yīng)用的關(guān)閉事件
 */
@Slf4j
@Component
public class ShutdownListener implements ApplicationListener<ContextClosedEvent> {
    @Override
    public void onApplicationEvent(ContextClosedEvent event) {

        log.info("應(yīng)用正在關(guān)閉...");

        // 中斷所有正在運(yùn)行的任務(wù)
        TaskExecutorUtil.stopAllTasks();

        // 等待所有任務(wù)完成
        TaskExecutorUtil.waitForTasksToComplete();

        log.info("應(yīng)用已經(jīng)關(guān)閉...");
    }
}

package com.angel.ocean.tool.runner;

import com.angel.ocean.tool.task.MyTask;
import com.angel.ocean.tool.util.TaskExecutorUtil;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.stereotype.Component;

@Component
public class MyTaskRunner implements ApplicationRunner {

    @Override
    public void run(ApplicationArguments args) throws Exception {
        // 創(chuàng)建并執(zhí)行任務(wù)
        MyTask task = new MyTask();
        TaskExecutorUtil.executeTask(task);
        System.out.println("任務(wù)已啟動(dòng)...");
    }
}

package com.angel.ocean.tool.task;

import com.angel.ocean.tool.util.TaskExecutorUtil;
import lombok.extern.slf4j.Slf4j;

@Slf4j
public class MyTask extends CommonTask {
    @Override
    public void handler() {
        while (TaskExecutorUtil.isRunning) {
            log.info("本次任務(wù)開(kāi)始執(zhí)行.......");
            try {
                for(int i = 0; i < 10; i++) {
                    // 模擬任務(wù)執(zhí)行時(shí)間，等待1s
                    Thread.sleep(1000);
                    log.info("i = {}", i);
                }
                log.info("本次任務(wù)執(zhí)行完成.......");
            } catch (InterruptedException e) {
                // 處理中斷請(qǐng)求
                Thread.currentThread().interrupt();
                log.info("任務(wù)被中斷.......");
            }
        }
    }
}

package com.angel.ocean.tool.task;

import lombok.extern.slf4j.Slf4j;

/**
 * Task抽象類(lèi)
 */
@Slf4j
public abstract class CommonTask implements Runnable {

    @Override
    public void run() {
        handler();
    }

    public void handler() {

    }
}