在 Spring Boot 中终止先前运行的函数并启动新函数

package com.springbootLogging.demo;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.web.bind.annotation.CrossOrigin;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.Map;
import java.util.UUID;
import java.util.concurrent.ConcurrentHashMap;

@RestController
@RequestMapping(path="/")
public class AppController {

    Logger logger = LoggerFactory.getLogger(AppController.class);

    private static volatile Map<String, Thread> threadLookup = new ConcurrentHashMap<>();

    @CrossOrigin
    @GetMapping(path="/startLog")
    public String startPrintingLogs() {
        UUID uuid = UUID.randomUUID();
        String uuidString = uuid.toString();

        Thread thread = new Thread(() -> {
            while(!Thread.currentThread().isInterrupted()) {
                logger.debug("It is a debug logger.");
                logger.error("It is an error logger.");
                logger.info("It is an info logger.");
                logger.trace("It is a trace logger.");
                logger.warn("It is a warn logger.");

                try {
                    Thread.sleep(100); // 控制日志输出频率
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt(); // 重新设置中断标志
                    logger.warn("Thread interrupted: " + uuidString);
                }
            }
            logger.info("Thread stopped: " + uuidString);
        });

        thread.start();
        threadLookup.put(uuidString, thread);

        return uuidString; // 返回 UUID，用于停止线程
    }

    @CrossOrigin
    @GetMapping(path="/stopLog/{uuid}")
    public String stopPrintingLogs(@PathVariable String uuid) {
        Thread thread = threadLookup.get(uuid);
        if (thread == null) {
            return "Thread not found with UUID: " + uuid;
        } else {
            thread.interrupt();
            threadLookup.remove(uuid);
            return "Thread interrupted with UUID: " + uuid;
        }
    }
}