Java动态添加Scheduled的实现方式
引言
在Java中，动态添加Scheduled定时任务可以通过多种方式实现，其中最常见的是使用Spring框架提供的@Scheduled注解结合SchedulingConfigurer接口，以及通过ThreadPoolTaskScheduler来管理任务的调度。此外，还可以利用ScheduledExecutorService来创建和管理定时任务。下面将详细介绍如何在Spring环境中动态地添加、修改和取消定时任务。
使用SchedulingConfigurer和ThreadPoolTaskScheduler
Spring提供了SchedulingConfigurer接口，它允许开发者自定义调度器配置，从而能够更灵活地控制定时任务的行为。要实现动态添加定时任务，首先需要创建一个实现了SchedulingConfigurer接口的配置类，并在这个类中注入ScheduledTaskRegistrar实例。这样做的好处是可以直接访问到ScheduledTaskRegistrar，进而可以调用其提供的API来注册新的任务或更新已有的任务。
@Slf4j
@EnableScheduling
@Configuration
public class SchedulerConfig implements SchedulingConfigurer {
private final ScheduledTaskRegistrar taskRegistrar;
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
this.taskRegistrar = taskRegistrar;
ThreadPoolTaskScheduler taskScheduler = threadPoolTaskScheduler();
taskRegistrar.setScheduler(taskScheduler);
}
@Bean
public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
scheduler.setPoolSize(Runtime.getRuntime().availableProcessors() / 3 + 1);
scheduler.setThreadNamePrefix("scheduler-");
scheduler.setRemoveOnCancelPolicy(true);
return scheduler;
}
}
接下来，在应用程序启动后或者根据业务逻辑的需求，可以通过taskRegistrar来添加新的定时任务。例如，我们可以定义一个方法来创建并调度一个新的Cron任务：
@Autowired
private ScheduledTaskRegistrar taskRegistrar;
public ScheduledTask addCronTask(String cronExpression, Runnable task) {
CronTask cronTask = new CronTask(task, new CronTrigger(cronExpression));
return taskRegistrar.scheduleCronTask(cronTask);
}
这里，addCronTask方法接收两个参数：一个是cron表达式，用于指定任务的执行时间；另一个是Runnable类型的任务对象，表示具体要执行的操作。该方法返回一个ScheduledTask实例，可用于后续的任务管理和取消操作。
动态修改和取消定时任务
除了添加新的定时任务外，我们还可能需要在运行时修改现有任务的执行周期或者完全取消某个任务。对于基于ScheduledTaskRegistrar创建的任务，可以通过保存每个任务对应的ScheduledTask对象来实现这一点。当需要更改任务的执行周期时，可以先取消旧的任务，然后重新创建一个新的任务：
public void updateCronTask(ScheduledTask oldTask, String newCronExpression, Runnable task) {
if (oldTask != null) {
oldTask.cancel(true);
}
addCronTask(newCronExpression, task);
}
如果只是想暂停某个任务而不立即删除它，可以调用ScheduledTask的cancel(boolean mayInterruptIfRunning)方法，传入true表示允许中断正在执行的任务。之后，可以根据需要决定是否重新启动该任务。
使用ScheduledExecutorService
除了上述基于Spring的方式之外，ScheduledExecutorService也是一种非常有效的手段，特别是在不需要依赖Spring上下文的情况下。ScheduledExecutorService提供了简单易用的API来安排命令在未来某一时刻执行，既可以是一次性的也可以是周期性的。下面是一个简单的例子，展示了如何使用ScheduledExecutorService来动态添加定时任务：
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class DynamicScheduledTaskExample {
private static final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(2);
public static void main(String[] args) {
// 添加一个每5秒执行一次的任务
scheduler.scheduleAtFixedRate(() -> System.out.println("Executing task at fixed rate"), 0, 5, TimeUnit.SECONDS);
// 模拟一段时间后的动态添加新任务
try {
Thread.sleep(10000); // 等待10秒
} catch (InterruptedException e) {
e.printStackTrace();
}
// 添加一个每10秒执行一次的新任务
scheduler.scheduleAtFixedRate(() -> System.out.println("Executing another task at fixed rate"), 0, 10, TimeUnit.SECONDS);
}
}
在这个例子中，我们首先创建了一个包含两个线程的ScheduledExecutorService实例。然后，我们使用scheduledAtFixedRate方法来安排两个不同的任务，它们分别以5秒和10秒的时间间隔重复执行。需要注意的是，与Spring中的@Scheduled不同，ScheduledExecutorService不会自动管理任务的生命周期，因此必须手动确保资源的正确释放。
结合数据库持久化
为了使定时任务更加健壮和易于管理，通常会将任务的相关信息（如cron表达式、状态等）存储在数据库中。这样不仅可以方便地对任务进行查询和维护，而且可以在应用重启后恢复之前的状态。例如，可以设计一张名为schedule_setting的表来保存定时任务的元数据：
CREATE TABLE IF NOT EXISTS `schedule_setting` (
`job_id` int NOT NULL AUTO_INCREMENT COMMENT '任务ID',
`bean_name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT 'bean名称',
`method_name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '方法名称',
`method_params` varchar(8192) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '方法参数',
`cron_expression` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT 'cron表达式',
`remark` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '备注',
`job_status` tinyint(1) DEFAULT NULL COMMENT '状态(1为启用,0为停用)',
`create_time` datetime DEFAULT NULL COMMENT '创建时间',
`update_time` datetime DEFAULT NULL COMMENT '修改时间',
PRIMARY KEY (`job_id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
通过这种方式，可以轻松地实现定时任务的持久化，并且可以在需要时从数据库读取任务配置，动态地加载或更新任务。
综上所述，无论是使用Spring内置的支持还是借助ScheduledExecutorService，都可以有效地实现在Java应用程序中动态添加、修改和取消定时任务的功能。选择哪种方式取决于具体的项目需求和技术栈。如果你已经在使用Spring Boot，那么推荐采用前者，因为它与框架集成得更好，同时也提供了更多的特性和便利性。而对于那些不依赖于Spring的应用程序来说，ScheduledExecutorService则是一个轻量级且高效的选择。
以上就是Java动态添加Scheduled的实现方式的详细内容，更多关于Java动态添加Scheduled的资料请关注脚本之家其它相关文章！
相关文章
这篇文章主要介绍了如何基于Jenkins构建Jmeter项目,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-09-09
本篇文章,我们通过 MyBatis Plus 来对一张表进行 CRUD 操作,来看看是如何简化我们开发的,文中通过代码示例介绍的非常详细,对大家的学习或工作有一定的帮助,需要的朋友可以参考下2024-05-05
mybatis-plus分页查询total=0问题及解决方案
这篇文章主要介绍了mybatis-plus分页查询total=0问题及解决方案,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2026-03-03
这篇文章主要介绍了java实现微信公众平台发送模板消息的示例代码，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-09-09
这篇文章主要介绍了Java获得指定区间数的方法,涉及java数值运算的相关技巧,需要的朋友可以参考下2015-05-05
prometheus数据远程写入elasticsearch方式
这篇文章主要介绍了prometheus数据远程写入elasticsearch方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2025-06-06
这篇文章主要介绍了Spring Boot 集成MyBatis 教程详解,非常不错，具有参考借鉴价值，需要的朋友可以参考下2017-04-04
慢sql提前分析预警和动态sql替换-Mybatis-SQL
为防止慢SQL问题而开发的MyBatis组件,该组件能够在开发、测试阶段自动分析SQL语句,并在出现慢SQL问题时通过Ducc配置实现动态替换,从而快速止损2025-05-05
这篇文章主要介绍了Spring Boot如何获取maven打包时间,首先引入maven打包插件,本文分步骤给大家介绍的非常详细,需要的朋友参考下吧2024-03-03
博主的毕设系统在做一个餐厅的点餐管理系统，在进行移动端页面开发的时候突发奇想做一个呼叫功能，因此就有了这篇文章2021-05-05
最新评论