Springboot中实现手动启动和暂停任务的功能

importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
importorg.springframework.scheduling.support.CronTrigger;
importorg.springframework.stereotype.Service;
importjava.util.concurrent.ScheduledFuture;
@ServicepublicclassManualScheduledTaskService {
privateThreadPoolTaskSchedulerscheduler;
privateRunnabletask;
privateScheduledFuture<?>taskFuture;
@AutowiredpublicManualScheduledTaskService(ThreadPoolTaskSchedulerscheduler) {
this.scheduler=scheduler;
this.task= () ->System.out.println("定时任务执行："+System.currentTimeMillis());
    }
publicvoidstartTask(StringcronExpression) {
if (taskFuture==null||taskFuture.isCancelled()) {
taskFuture=scheduler.schedule(task, newCronTrigger(cronExpression));
        }
    }
publicvoidstopTask() {
if (taskFuture!=null) {
taskFuture.cancel(true);
        }
    }
publicbooleanisTaskRunning() {
returntaskFuture!=null&&!taskFuture.isCancelled();
    }
}

importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.web.bind.annotation.GetMapping;
importorg.springframework.web.bind.annotation.PostMapping;
importorg.springframework.web.bind.annotation.RequestParam;
importorg.springframework.web.bind.annotation.RestController;
@RestControllerpublicclassManualScheduledTaskController {
privateManualScheduledTaskServicescheduledTaskService;
@AutowiredpublicManualScheduledTaskController(ManualScheduledTaskServicescheduledTaskService) {
this.scheduledTaskService=scheduledTaskService;
    }
@PostMapping("/startTask")
publicStringstartTask(@RequestParam("cronExpression") StringcronExpression) {
scheduledTaskService.startTask(cronExpression);
return"定时任务已开始，cron表达式："+cronExpression;
    }
@GetMapping("/stopTask")
publicStringstopTask() {
scheduledTaskService.stopTask();
return"定时任务已停止";
    }
@GetMapping("/isTaskRunning")
publicbooleanisTaskRunning() {
returnscheduledTaskService.isTaskRunning();
    }
}