Springboot多线程并发定时任务

Springboot多线程并发定时任务

刚刚看了下Spring Boot实现定时任务的文章,感觉还不错。Spring Boot 使用Spring自带的Schedule来实现定时任务变得非常简单和方便。

  • 开启缓存注解
1
2
3
4
5
6
7
8
@SpringBootApplication
@EnableScheduling //开启定时任务
public class Application {

public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
  • 编写定时任务
1
2
3
4
5
6
7
8
9
10
11
12
@Component
public class ScheduledTasks {

private Logger logger = LoggerFactory.getLogger(ScheduledTasks.class);

// cron接受cron表达式,根据cron表达式确定定时规则
@Scheduled(cron="0/5 * * * * ? ") //每5秒执行一次
public void testCron() {
DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
logger.info(sdf.format(new Date())+"*********每5秒执行一次");
}
}
  • 存在问题

后来发现个问题,通过同时测试几个任务发现,所有的任务都是在同一个线程池中的同一个线程来完成的。在实际开发过程中,我们当然不希望所有的任务都运行在一个线程中。

  • 解决方案

那么,怎么设计成多线程实现并发呢?在网上看到过这样的解决方案。通过ScheduleConfig配置文件实现SchedulingConfigurer接口,并重写setSchedulerfang方法,我们尝试着配置了一下。

1
2
3
4
5
6
7
8
@Configuration
public class ScheduleConfig implements SchedulingConfigurer {
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {

taskRegistrar.setScheduler(Executors.newScheduledThreadPool(5));
}
}
  • 其他
1
2
3
4
5
6
7
8
9
@Scheduled所支持的参数:
1.cron:cron表达式,指定任务在特定时间执行;
2.fixedDelay:表示上一次任务执行完成后多久再次执行,参数类型为long,单位ms;
3.fixedDelayString:与fixedDelay含义一样,只是参数类型变为String;
4.fixedRate:表示按一定的频率执行任务,参数类型为long,单位ms;
5.fixedRateString: 与fixedRate的含义一样,只是将参数类型变为String;
6.initialDelay:表示延迟多久再第一次执行任务,参数类型为long,单位ms;
7.initialDelayString:与initialDelay的含义一样,只是将参数类型变为String;
8.zone:时区,默认为当前时区,一般没有用到。

参考链接:

-------------已经触及底线 感谢您的阅读-------------

本文标题:Springboot多线程并发定时任务

文章作者:趙小傑~~

发布时间:2019年03月24日 - 16:04:00

最后更新:2019年07月26日 - 23:32:12

原始链接:https://cnsyear.com/posts/6ceab069.html

许可协议: 署名-非商业性使用-禁止演绎 4.0 国际 转载请保留原文链接及作者。

0%