Java定时任务

一、java.util.Timer

java.util.Timer 类允许您在未来的某个时间执行一个任务，或者在一定的时间间隔执行任务。您可以创建一个 Timer 实例，并调用其 schedule() 方法来安排任务的执行。这种方式比较简单，但在高并发环境下可能不够灵活。

1.代码实现

Timer timer = new Timer();//延迟1s，每个2s打印一次timer.schedule(new TimerTask() {@Overridepublic void run() {System.out.println("111111111111");}}, 1000,2000);

2.常用方法

Timer 常用方法

二、java.util.concurrent.Executors

Java 提供了 ExecutorService 和 ScheduledExecutorService 接口，以及一些工厂方法来创建线程池和调度执行任务。ScheduledExecutorService 可以用于执行延迟任务或周期性任务。

1.代码实现

ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);
scheduledExecutorService.scheduleAtFixedRate(()->{System.out.println("1111111");
},1,2, TimeUnit.SECONDS);

2.常用方法

在这里插入图片描述

三、Spring Framework 定时任务

1.启用定时任务功能：

在配置类上添加 @EnableScheduling 注解，以启用 Spring 的定时任务功能。

@SpringBootApplication
@EnableScheduling
public class Application {public static void main(String[] args) {SpringApplication.run(Application.class,args);}
}

2.创建定时任务方法：

在 Spring 管理的 Bean 类中定义一个方法，并使用 @Scheduled 注解标记该方法作为定时任务。可以指定定时任务的触发时间、频率等。

@RestController
public class ScheduledTasksController {@Scheduled(cron = "0 30 9 * * ?")//每天九点半执行public void task1(){System.out.println("111111111");}@Scheduled(fixedRate = 5000)//每个5s执行public void task2(){System.out.println("222222222");}
}

3.cron表达式

每隔5秒执行一次：*/5 * * * * ?
每隔1分钟执行一次：0 */1 * * * ?
每天22点执行一次：0 0 22 * * ?
每天凌晨1点执行一次：0 0 1 * * ?
每月1号凌晨1点执行一次：0 0 1 1 * ?
每月最后一天21点执行一次：0 0 21 L * ?
每周星期天凌晨1点实行一次：0 0 1 ? * L
在12分、13分、14分执行一次：0 12,13,14 * * * ?
每天的0点、3点、5点、7点都执行一次：0 0 0, 3,5,7 * * ?
Java检测cron表达式
先引入quartz的jar包

<dependency><groupId>org.quartz-scheduler</groupId><artifactId>quartz</artifactId><version>2.3.2</version>
</dependency>

检测代码

boolean validExpression = CronExpression.isValidExpression(cron);
if (validExpression) {//cron验证通过
} else {//cron颜值失败
}

四、动态配置定时时间

1.通过yml配置：

问题： 每次修改时间都需要重新启动服务；

@Component
@Slf4j
public class DynamicScheduledTaskRegistrar {@Resourceprivate TaskScheduler taskScheduler;@Value("${schedule.cron}")private String cronExpression;@PostConstructpublic void init() {scheduleTask();}private void scheduleTask() {Runnable task = () -> {//业务逻辑};Trigger trigger = new CronTrigger(cronExpression);taskScheduler.schedule(task, trigger);}
}

2.通过set动态配置

方式一

@Component
@Slf4j
public class DynamicScheduledTaskRegistrar {@Resourceprivate TaskScheduler taskScheduler;private ScheduledFuture<?> scheduledFuture;private String cronExpression = "*/10 * * * * *"; // 默认的cron表达式@PostConstructpublic void init() {scheduleTask();}private void scheduleTask() {Runnable task = () -> {// 这里写你的定时任务逻辑System.out.println("执行定时任务");};Trigger trigger = new CronTrigger(cronExpression);scheduledFuture = taskScheduler.schedule(task, trigger);}public void setCronExpression(String newCronExpression) {this.cronExpression = newCronExpression;// 取消之前的定时任务并重新调度if (scheduledFuture != null && !scheduledFuture.isCancelled()) {scheduledFuture.cancel(true);}scheduleTask();}
}

方式二

1.首先配置taskScheduler

@Configuration
@EnableScheduling
public class SchedulingConfig {@Beanpublic TaskScheduler taskScheduler() {ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();scheduler.setPoolSize(10); // 设置线程池大小scheduler.setThreadNamePrefix("ScheduledTask-");scheduler.initialize();return scheduler;}
}

2.实现SchedulingConfigurer

@Component
@Slf4j
public class DynamicScheduledTask implements SchedulingConfigurer {private String cronExpression = ""; //cron 表达式private ScheduledFuture<?> scheduledFuture;private final TaskScheduler taskScheduler;public DynamicScheduledTask(TaskScheduler taskScheduler) {this.taskScheduler = taskScheduler;}@Overridepublic void configureTasks(ScheduledTaskRegistrar taskRegistrar) {scheduledFuture = taskScheduler.schedule(this::executeTask, new CronTrigger(cronExpression));}public void setCronExpression(String cronExpression) {this.cronExpression = cronExpression;// 根据新的 cron 表达式重新调度任务scheduledFuture.cancel(false);scheduledFuture = taskScheduler.schedule(this::executeTask, new CronTrigger(cronExpression));}public void executeTask() {// 定时任务执行的操作System.out.println("执行定时任务");}
}