Sring执行器系统状态缺少调度程序数据,以编程添加调度程序

发布于 2025-02-03 13:25:42 字数 1860 浏览 3 评论 0 原文

我正在使用Java 11,Spring Boot。我的调度程序运行 @scheduled 注释,它们出现在执行器页面:##/Administion/Systemstatus 自动。但是从现在开始,我必须提供有可能从UI强行安排任务的可能性要根据应用程序的某些cron表达再次安排此任务。这使我写下了自己的调度组件,因为我发现不可能用@schedule注释来完成所有这些内容。但是作为副作用,我没有有关任务及其CRON表达式的数据。以下是代码,我仅包括一个零件,该部分在部署应用程序时将任务添加到调度程序中。我没有添加重新安排操作。您知道如何修复执行器数据吗?

@Component
@Slf4j
public class MyTaskService {

    private final TaskScheduler scheduler;
    private final List<CustomTask> taskList; //runnable tasks
    private final RunningTasksFutureHolder runningTasksFutureHolder;

    public MyTaskService(TaskScheduler scheduler,
                               List<CustomTask> taskList,
                               RunningTasksFutureHolder runningTasksFutureHolder) {
        this.scheduler = scheduler;
        this.taskList = taskList;
        this.runningTasksFutureHolder = runningTasksFutureHolder;
    }

    @PostConstruct
    public void afterLoad() {
        askList.forEach(this::addTaskToScheduler);
    }

    public void addTaskToScheduler(CustomTask task) {
    //here tasks are added to scheduler and they are not visible in actuator
        ScheduledFuture<?> scheduledTask = scheduler.schedule(task, new CronTrigger(task.getCronExpression()));
        runningTasksFutureHolder.add(task.getTaskType(), scheduledTask);
    }

}





@Configuration
@EnableScheduling
public class SchedulingConfig implements SchedulingConfigurer {

    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        //do nothing here
    }

    @Bean
    public TaskScheduler poolScheduler() {
        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
        scheduler.setThreadNamePrefix("ThreadPoolTaskScheduler");
        scheduler.setPoolSize(5);
        scheduler.initialize();
        return scheduler;
    }
}

I am using Java 11, Spring Boot. I had my schedulers running with @Scheduled annotation and they appeared in Actuator page: #/administration/systemstatus automatically. But since now I have to provide possibility to schedule a task forcibly from UI I have to invoke schedule operation on TaskScheduler for such task for current time and after it ends, I have to again schedule such task according to some cron expression from application.properties (because schedule operations changes the scheduled time and I tasks generally have to be working on specified cron times and only sometimes will be additionally triggered by user form UI). That lead me to write my own scheduling component as I found it impossible to do all of this with @Schedule annotation. But as a side effect I don't have data about tasks and their cron expressions in actuator systemstatus. Below is the code, I include only a part that adds tasks to scheduler when application is deployed. I am not adding reschedule operations. Do u know how to repair the actuator data ?

@Component
@Slf4j
public class MyTaskService {

    private final TaskScheduler scheduler;
    private final List<CustomTask> taskList; //runnable tasks
    private final RunningTasksFutureHolder runningTasksFutureHolder;

    public MyTaskService(TaskScheduler scheduler,
                               List<CustomTask> taskList,
                               RunningTasksFutureHolder runningTasksFutureHolder) {
        this.scheduler = scheduler;
        this.taskList = taskList;
        this.runningTasksFutureHolder = runningTasksFutureHolder;
    }

    @PostConstruct
    public void afterLoad() {
        askList.forEach(this::addTaskToScheduler);
    }

    public void addTaskToScheduler(CustomTask task) {
    //here tasks are added to scheduler and they are not visible in actuator
        ScheduledFuture<?> scheduledTask = scheduler.schedule(task, new CronTrigger(task.getCronExpression()));
        runningTasksFutureHolder.add(task.getTaskType(), scheduledTask);
    }

}





@Configuration
@EnableScheduling
public class SchedulingConfig implements SchedulingConfigurer {

    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        //do nothing here
    }

    @Bean
    public TaskScheduler poolScheduler() {
        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
        scheduler.setThreadNamePrefix("ThreadPoolTaskScheduler");
        scheduler.setPoolSize(5);
        scheduler.initialize();
        return scheduler;
    }
}

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

小伙你站住 2025-02-10 13:25:43

您应该直接使用 scheduledtaskregistrar 直接调用 taskscheduler 。对于CRON任务,相应的方法为 addCrontask()

参考:

You should use ScheduledTaskRegistrar rather than calling TaskScheduler directly. For the cron task the corresponding method is addCronTask().

References:

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文