当前位置:   article > 正文

【JAVA】@Scheduledcron使用详解和参数周期规则_java scheduled cron

java scheduled cron


提示:以下是本篇文章正文内容,下面案例可供参考

一、@Scheduled是什么?

@Scheduled 注解是Spring框架中用于支持定时任务的注解之一。通过该注解,你可以指定方法在特定的时间间隔或者按照特定的时间表执行。

二、使用步骤

1.在启动类或者配置类上添加@EnableScheduling

@SpringBootApplication
@ComponentScan("com.example.demo.faultmgnt")
@EnableScheduling
public class DemoApplication {
    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8

2.在方法上标注@Scheduled用来标识定时任务

代码如下(示例):

    //表示从零秒开始每隔五秒执行一次
    @Scheduled(cron="0/5 * * * * *")
    public void execute() throws InterruptedException {
     System.out.println("定时任务开始执行");
    }
  • 1
  • 2
  • 3
  • 4
  • 5

三、参数详解

@Target({ElementType.METHOD, ElementType.ANNOTATION_TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Repeatable(Schedules.class)
public @interface Scheduled {
    String CRON_DISABLED = "-";

    String cron() default "";

    String zone() default "";

    long fixedDelay() default -1L;

    String fixedDelayString() default "";

    long fixedRate() default -1L;

    String fixedRateString() default "";

    long initialDelay() default -1L;

    String initialDelayString() default "";

    TimeUnit timeUnit() default TimeUnit.MILLISECONDS;
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25

1、cron用法

@Scheduled(cron="0/5 * * * * *")
    public void execute() throws InterruptedException {
        String name =  Thread.currentThread().getName();
        System.out.println(Thread.currentThread().getName()+"开始"+ LocalDateTime.now());
        Thread.sleep(6000);
        System.out.println(name+"结束"+"i的值:"+LocalDateTime.now());
    }
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7

如果使用Cron来指定周期的话,当任务执行时间大于指定的执行周期,会漏掉部分任务执行,假如上面代码在2024-01-10T17:06:55.027 开始执行到2024-01-10T17:07:15.009 ,
1、如果任务执行时间小于执行周期应该会执行五次
2、如果任务执行时间大于执行周期会漏掉任务执行,参考上面代码,打印结果如下,只执行了三次周期,2024-01-10T17:07:00和2024-01-10T17:07:10的时候理论上会执行,上一个任务没有执行完会自动跳过

//任务执行时间大于任务执行周期打印结果
taskScheduler-1开始2024-01-10T17:06:55.027
taskScheduler-1结束2024-01-10T17:07:01.041

taskScheduler-1开始2024-01-10T17:07:05.007
taskScheduler-1结束2024-01-10T17:07:11.008

taskScheduler-1开始2024-01-10T17:07:15.009
taskScheduler-1结束2024-01-10T17:07:21.020
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9

2、fixedRate用法

//每隔五秒执行    fixedRate默认单位为毫秒
 @Scheduled(fixedRate=5000)
    public void execute() throws InterruptedException {
        String name =  Thread.currentThread().getName();
        System.out.println(Thread.currentThread().getName()+"开始"+ LocalDateTime.now());
        Thread.sleep(6000);
        System.out.println(name+"结束"+LocalDateTime.now());
    }
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8

打印结果如下

taskScheduler-1开始2024-01-10T17:16:55.825
taskScheduler-1结束2024-01-10T17:17:01.827
taskScheduler-1开始2024-01-10T17:17:01.827
taskScheduler-1结束2024-01-10T17:17:07.830
taskScheduler-1开始2024-01-10T17:17:07.830
taskScheduler-1结束2024-01-10T17:17:13.832
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6

使用fixedRate进行指定周期,根据打印结果会发现当下一个执行周期开始的时候,上一个任务没有执行完会进行等待上一个任务执行完成后立即去执行

3、fixedDelay用法

@Scheduled(fixedDelay=5000)
    public void execute() throws InterruptedException {
        String name =  Thread.currentThread().getName();
        System.out.println(Thread.currentThread().getName()+"开始"+ LocalDateTime.now());
        Thread.sleep(6000);
        System.out.println(name+"结束"+LocalDateTime.now());
    }
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7

打印结果如下

taskScheduler-1开始2024-01-10T17:22:01.593
taskScheduler-1结束2024-01-10T17:22:07.594

taskScheduler-1开始2024-01-10T17:22:12.601
taskScheduler-1结束2024-01-10T17:22:18.609

taskScheduler-1开始2024-01-10T17:22:23.618
taskScheduler-1结束2024-01-10T17:22:29.624
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8

根据打印结果,判断使用fixedDelay进行指定执行周期的情况,每个任务执行时间无论多久,都会在任务执行后完成后相隔五秒去执行下一个任务

四、多个定时任务同时执行

配置线程池,增加线程的数量

如果没有指定线程池的话,默认是单线程去执行定时任务的,比如有两个定时任务同一时间执行,都是每隔五秒去执行,单线程下只会去执行一个定时任务,执行完后才会执行另一个定时任务,如何解决这个问题
只需要自己配置一下线程池的大小,增加下线程数量

 @Bean
    public TaskScheduler taskScheduler() {
        ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
        taskScheduler.setPoolSize(50);
        return taskScheduler;
    }
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/小丑西瓜9/article/detail/728260
推荐阅读
相关标签
  

闽ICP备14008679号