Spring Scheduler状态查询与重复启动异常配置方法

针对你的场景（Spring Boot 2.0.0，实现SchedulingConfigurer接口通过API启动调度器），我会分两部分给出实用解决方案：

一、查询调度器的运行状态 #

Spring自带的TaskScheduler没有直接暴露"活跃/非活跃"的状态接口，但我们可以通过自定义状态标记+ScheduledFuture实例追踪来实现准确的状态查询，具体步骤如下：

1. 在你的启动类中，保存TaskScheduler实例、调度任务的ScheduledFuture对象，以及一个自定义的活跃状态标记：

@SpringBootApplication
@RestController
public class SchedulerApplication implements SchedulingConfigurer {

    private ThreadPoolTaskScheduler taskScheduler;
    private ScheduledFuture<?> scheduledTask;
    // 标记调度器是否处于活跃状态
    private boolean isSchedulerActive = false;

    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        // 初始化自定义线程池调度器
        taskScheduler = new ThreadPoolTaskScheduler();
        taskScheduler.setPoolSize(3);
        taskScheduler.setThreadNamePrefix("my-scheduler-");
        taskScheduler.initialize();
        taskRegistrar.setTaskScheduler(taskScheduler);
    }

2. 添加查询状态的API接口，结合标记位和ScheduledFuture的状态判断（避免标记位和实际任务状态不一致）：

@GetMapping("/scheduler/status")
    public Map<String, Object> getSchedulerStatus() {
        boolean actuallyRunning = scheduledTask != null && !scheduledTask.isCancelled() && !scheduledTask.isDone();
        // 更新标记位以保证一致性
        isSchedulerActive = actuallyRunning;
        
        return Map.of(
            "status", isSchedulerActive ? "ACTIVE" : "INACTIVE",
            "activeThreads", taskScheduler.getActiveCount(),
            "taskIsDone", scheduledTask != null ? scheduledTask.isDone() : true
        );
    }

这里额外通过taskScheduler.getActiveCount()获取当前活跃的调度线程数，可以作为状态的辅助参考。

二、重复启动时抛出异常 #

要实现"再次启动同一调度器时抛出异常"，只需在启动API中先校验当前调度器的活跃状态，若已运行则直接抛出自定义异常：

1. 编写启动调度器的API，并添加状态校验：

@PostMapping("/scheduler/start")
    public String startScheduler() {
        // 校验是否已在运行
        boolean isRunning = scheduledTask != null && !scheduledTask.isCancelled() && !scheduledTask.isDone();
        if (isRunning) {
            // 抛出非法状态异常，你也可以自定义业务异常
            throw new IllegalStateException("调度器已处于运行状态，无法重复启动");
        }

        // 启动调度任务
        scheduledTask = taskScheduler.scheduleAtFixedRate(() -> {
            try {
                // 你的调度任务逻辑
                System.out.println("调度任务执行中：" + LocalDateTime.now());
            } catch (Exception e) {
                // 可选：任务执行异常时，根据需求决定是否终止调度器
                // scheduledTask.cancel(false);
                // isSchedulerActive = false;
                log.error("调度任务执行失败", e);
            }
        }, Duration.ofSeconds(5));
        
        isSchedulerActive = true;
        return "调度器启动成功";
    }

2. 可选：添加全局异常处理器，将异常转换为友好的HTTP响应：

@RestControllerAdvice
    static class GlobalExceptionHandler {
        @ExceptionHandler(IllegalStateException.class)
        public ResponseEntity<String> handleSchedulerRunningException(IllegalStateException ex) {
            // 返回409 Conflict状态码表示资源冲突
            return ResponseEntity.status(HttpStatus.CONFLICT).body(ex.getMessage());
        }
    }

这样当用户重复调用启动API时，会收到明确的异常提示，知晓调度器已在运行。

注意事项 #

• 如果你的调度任务可能因未捕获的异常终止，一定要在任务逻辑中添加异常捕获，避免任务意外停止导致状态标记与实际情况不符。
• 若需要支持调度器的停止功能，可以添加对应的API，调用scheduledTask.cancel(false)并更新isSchedulerActive标记。

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