Spring 中,@Scheduled 注解的使用方法 |
您所在的位置：网站首页 › java定时任务scheduledService原理 › Spring 中,@Scheduled 注解的使用方法 |
Spring 中,@Scheduled 注解的使用方法
|
Spring 中,@Scheduled 注解的使用方法 Spring 提供了@Scheduled 注解，良好的解决了定时任务的需求，它的实现本质是基于 java 中的 ScheduledExecutorService 类的 schedule 方法。 @Scheduled 注解标注在方法上，它是 Spring 实现的一种计划任务，可以支持如下几种方式运行： 固定时间频率运行方法。 延迟指定的时间运行方法。 按照 cron 表达式定义的时间方式运行方法。（cron 表达式的基本概念，自行查找相关材料。） 代码语言：javascript复制@Scheduled(fixedDelay =30000) public void doJob() { } @Scheduled(fixedRate=30000) public void doJob() { } @Scheduled(cron="0 0 * * * *") public void doJob() { }使用@Scheduled 注解的时，按如下步骤： 1. 配置文件中，打开运行执行 Schedule 任务的开关，使用注解 @EnableScheduling。 2. 将某个类的方法标注@Scheduled。 3. 启动 Spring 容器应用。 使用注解@EnableScheduling。 代码语言：javascript复制@Configuration @ComponentScan(value = "com.learn") @EnableScheduling public class Config { }在方法上标注@Scheduled。 代码语言：javascript复制@Component public class ScheduledTaskService { @Scheduled(fixedRate = 1000) //使用fixedRate属性每隔1秒执行 public void doJob(){ System.out.println("doJob..." + Thread.currentThread().getName() + "," + new Date()); } }启动 Spring 容器。 代码语言：javascript复制public static void main(String[] args) { // 使用Config.class这个配置类 AnnotationConfigApplicationContext applicationContext = new AnnotationConfigApplicationContext(Config.class); //防止主进程立即运行完毕，延迟10秒退出主进程 try { Thread.sleep(10000); } catch (InterruptedException e) { e.printStackTrace(); } applicationContext.close(); }结果, 每隔一秒执行一次函数。同一个线程执行: 代码语言：javascript复制doJob...pool-1-thread-1,Fri Sep 07 22:52:13 CST 2018 doJob...pool-1-thread-1,Fri Sep 07 22:52:14 CST 2018 doJob...pool-1-thread-1,Fri Sep 07 22:52:15 CST 2018 doJob...pool-1-thread-1,Fri Sep 07 22:52:16 CST 2018 doJob...pool-1-thread-1,Fri Sep 07 22:52:17 CST 2018 doJob...pool-1-thread-1,Fri Sep 07 22:52:18 CST 2018 doJob...pool-1-thread-1,Fri Sep 07 22:52:19 CST 2018 doJob...pool-1-thread-1,Fri Sep 07 22:52:20 CST 2018 doJob...pool-1-thread-1,Fri Sep 07 22:52:21 CST 2018 doJob...pool-1-thread-1,Fri Sep 07 22:52:22 CST 2018 doJob...pool-1-thread-1,Fri Sep 07 22:52:23 CST 2018默认单线程运行 @Schduled 默认是基于单线程执行, 所有的定时任务串行执行，这就可能导致运行时间久的任务，会影响到下一个运行周期的任务。参考下图了解影响点。  图片来自于网络（https://blog.csdn.net/applebomb/article/details/52400154） 如果需要基于多线程执行，则需要配置。可以在配置文件中加入如下代码： 代码语言：javascript复制如上的配置用于设置线程池，这样多个定时任务就可以并行执行。 基于注解的配置方式，就是在容器中，增加一个 ScheduledThreadPoolExecutor 类型的实例即可。 代码语言：javascript复制@Configuration public class AppConfig { @Bean public ScheduledThreadPoolExecutor scheduledExecutorService() { ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(5); return executor; } }修改一下运行任务的代码，运行 2 种任务。 代码语言：javascript复制@Component public class ScheduledTaskService { @Scheduled(fixedRate = 1000) //使用fixedRate属性每隔1秒执行 public void doJob1(){ System.out.println("doJob1..."+Thread.currentThread().getName()+","+new Date()); } @Scheduled(fixedRate = 2000) //使用fixedRate属性每隔2秒执行 public void doJob2(){ System.out.println("doJob2..."+Thread.currentThread().getName()+","+new Date()); } }运行结果如下： 代码语言：javascript复制doJob1...pool-1-thread-1,Fri Sep 07 22:55:00 CST 2018 doJob2...pool-1-thread-1,Fri Sep 07 22:55:00 CST 2018 doJob1...pool-1-thread-1,Fri Sep 07 22:55:01 CST 2018 doJob1...pool-1-thread-3,Fri Sep 07 22:55:02 CST 2018 doJob2...pool-1-thread-3,Fri Sep 07 22:55:02 CST 2018 doJob1...pool-1-thread-1,Fri Sep 07 22:55:03 CST 2018 doJob2...pool-1-thread-2,Fri Sep 07 22:55:04 CST 2018 doJob1...pool-1-thread-5,Fri Sep 07 22:55:04 CST 2018 doJob1...pool-1-thread-5,Fri Sep 07 22:55:05 CST 2018 doJob2...pool-1-thread-1,Fri Sep 07 22:55:06 CST 2018 doJob1...pool-1-thread-5,Fri Sep 07 22:55:06 CST 2018 doJob1...pool-1-thread-5,Fri Sep 07 22:55:07 CST 2018 doJob1...pool-1-thread-2,Fri Sep 07 22:55:08 CST 2018 doJob2...pool-1-thread-2,Fri Sep 07 22:55:08 CST 2018 doJob1...pool-1-thread-3,Fri Sep 07 22:55:09 CST 2018 doJob1...pool-1-thread-1,Fri Sep 07 22:55:10 CST 2018 doJob2...pool-1-thread-1,Fri Sep 07 22:55:10 CST 2018 |
【本文地址】
今日新闻 |
推荐新闻 |