springboot多线程定时任务

我们经常会遇到定时任务，在某个特定的时间点，程序会自主触发去执行一些机械重复的工作，这样就可以将人力与精力彻底的解放出来了。

在最近的工作中，先是在后台报表工程中用到了springboot自带的定时器标签 @EnableScheduling与 @Scheduled，使用 cron表达式完成定时任务，在凌晨整点时进行系统的数据统计工作；然后在今日又做了定时活动项目，指的是定时扫描数据库取出活动详情进行活动配置，每个活动有一个结束时间，在结束时也需要一个定时器去出发统计，其中定时时间做到可以实时配置，可以说是相当灵活了。

报表工程

1.报表工程使用最简单的定时，在springboot启动时加上如下配置就可以开启一个定时器

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

2.接下来在你服务类中的方法上加上如下标签以及相关cron表达式

    @Scheduled(cron = "0/2 * * * * *")public void timer(){//获取当前时间LocalDateTime localDateTime =LocalDateTime.now();System.out.println("当前时间为:" + localDateTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));}

对于cron表达式，其结构是: 从左到右（用空格隔开）：秒分小时月份中的日期月份星期中的日期年份

每一个域都使用数字，但还可以出现如下特殊字符，它们的含义是

　　（1）*：表示匹配该域的任意值。假如在Minutes域使用*, 即表示每分钟都会触发事件。

　　（2）?：只能用在DayofMonth和DayofWeek两个域。它也匹配域的任意值，但实际不会。因为DayofMonth和DayofWeek会相互影响。例如想在每月的20日触发调度，不管20日到底是星期几，则只能使用如下写法： 13 13 15 20 * ?, 其中最后一位只能用？，而不能使用*，如果使用*表示不管星期几都会触发，实际上并不是这样。

　　（3）-：表示范围。例如在Minutes域使用5-20，表示从5分到20分钟每分钟触发一次

　　（4）/：表示起始时间开始触发，然后每隔固定时间触发一次。例如在Minutes域使用5/20,则意味着5分钟触发一次，而25，45等分别触发一次.

　　（5）,：表示列出枚举值。例如：在Minutes域使用5,20，则意味着在5和20分每分钟触发一次。

　　（6）L：表示最后，只能出现在DayofWeek和DayofMonth域。如果在DayofWeek域使用5L,意味着在最后的一个星期四触发。

　　（7）W:表示有效工作日(周一到周五),只能出现在DayofMonth域，系统将在离指定日期的最近的有效工作日触发事件。例如：在 DayofMonth使用5W，如果5日是星期六，则将在最近的工作日：星期五，即4日触发。如果5日是星期天，则在6日(周一)触发；如果5日在星期一到星期五中的一天，则就在5日触发。另外一点，W的最近寻找不会跨过月份。

　　（8）LW:这两个字符可以连用，表示在某个月最后一个工作日，即最后一个星期五。

　　（9）#:用于确定每个月第几个星期几，只能出现在DayofMonth域。例如在4#2，表示某月的第二个星期三。

常用表达式例子

　　（1）0 0 2 1 * ? * 表示在每月的1日的凌晨2点调整任务

　　（2）0 15 10 ? * MON-FRI 表示周一到周五每天上午10:15执行作业

　　（3）0 15 10 ? 6L 2002-2006 表示2002-2006年的每个月的最后一个星期五上午10:15执行作

　　（4）0 0 10,14,16 * * ? 每天上午10点，下午2点，4点

　　（5）0 0/30 9-17 * * ? 朝九晚五工作时间内每半小时

　　（6）0 0 12 ? * WED 表示每个星期三中午12点

　　（7）0 0 12 * * ? 每天中午12点触发

　　（8）0 15 10 ? * * 每天上午10:15触发

　　（9）0 15 10 * * ? 每天上午10:15触发

　　（10）0 15 10 * * ? * 每天上午10:15触发

　　（11）0 15 10 * * ? 2005 2005年的每天上午10:15触发

　　（12）0 * 14 * * ? 在每天下午2点到下午2:59期间的每1分钟触发

　　（13）0 0/5 14 * * ? 在每天下午2点到下午2:55期间的每5分钟触发

　　（14）0 0/5 14,18 * * ? 在每天下午2点到2:55期间和下午6点到6:55期间的每5分钟触发

　　（15）0 0-5 14 * * ? 在每天下午2点到下午2:05期间的每1分钟触发

　　（16）0 10,44 14 ? 3 WED 每年三月的星期三的下午2:10和2:44触发

　　（17）0 15 10 ? * MON-FRI 周一至周五的上午10:15触发

　　（18）0 15 10 15 * ? 每月15日上午10:15触发

　　（19）0 15 10 L * ? 每月最后一日的上午10:15触发

　　（20）0 15 10 ? * 6L 每月的最后一个星期五上午10:15触发

　　（21）0 15 10 ? * 6L 2002-2005 2002年至2005年的每月的最后一个星期五上午10:15触发

　　（22）0 15 10 ? * 6#3 每月的第三个星期五上午10:15触发

活动工程

活动工程由于公司原因，此处展示本人做的迷你版本测试工程

1.首先当然是启动类加注解配置

package com.example.demo;import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;@SpringBootApplication
@MapperScan("com.example.demo.mapper")
@EnableScheduling
@Configuration
public class DemoApplication {public static void main(String[] args) {SpringApplication.run(DemoApplication.class, args);}
}

2.核心服务类中，一定要实现接口 SchedulingConfigurer

@Overridepublic void configureTasks(ScheduledTaskRegistrar taskRegistrar) {taskRegistrar.addTriggerTask(() -> {}, (triggerContext) -> {});}

实现借口了，当然要写好上面的定时任务调度了

3.进入核心定时服务类中，首先创建一个线程池调度器，这个是给每个活动任务添加定时任务用的，相当于一个定时任务容器，进行每个任务的生成。

 @Autowiredprivate ThreadPoolTaskScheduler threadPoolTaskScheduler;@Beanpublic ThreadPoolTaskScheduler threadPoolTaskScheduler() {return new ThreadPoolTaskScheduler();}

4.此处我将每个定时任务用线程启动，因此就需要一个线程的托管

private ScheduledFuture<?> future;

为了能够实时取得并删除该任务，我还需要一个容器记录线程的情况

private static Map<Integer, ScheduledFuture<?>> threadMap = new HashMap<>();

这样的话就可以实现定时去数据库取值，并将结果生成各个活动定时任务，完成自动处理，完整代码如下

 @Overridepublic void configureTasks(ScheduledTaskRegistrar taskRegistrar) {taskRegistrar.addTriggerTask(() -> {// 定时任务的业务逻辑//从数据库中取得开启状态的所有任务，与已经定时的任务做比较，新的任务开启新任务//传入参数：开始时间 结束时间 最小净买入量 最小持仓量 赠送的币种类型List<App> appList = testMapper.getActivityData();log.info(" === 进行最外层查询数据库内容 === " + new Date());for(App app : appList){if(app.getAppType() == 3){stopCron(app.getId());}else if(threadMap.get(app.getId()) == null){future = threadPoolTaskScheduler.schedule(new MyRunnable(app.getId()+""), new CronTrigger("0/5 * * * * *"));threadMap.put(app.getId(), future);}}}, (triggerContext) -> {// 定时任务触发，可修改定时任务的执行周期CronTrigger trigger = new CronTrigger(cron);Date nextExecDate = trigger.nextExecutionTime(triggerContext);return nextExecDate;});}

triggerContext返回为下一次执行的时间，是一个Date日期类型，其中需要在生成定时触发器CronTrigger 中加入实时的cron表达式，也就是这个时候进行了定时的切换，taskRegistrar.addTriggerTask只是进行业务逻辑的地方。

future = threadPoolTaskScheduler.schedule（任务，定时时间），此处的任务类我启用了线程，接收值是是之前声明的线程对象。ScheduledFuture只是在Future基础上还集成了Comparable和Delayed的接口。使其具有延迟、排序、获得异步计算结果的特性。以下是我的线程实现类

private class MyRunnable implements Runnable {private String c = "";public MyRunnable(String c){this.c = c;}@Overridepublic void run() {System.out.println("DynamicTask.MyRunnable.run()，" + c);}}

只是一个简单的输出而已

5.当需要停止定时任务时，使用Future对象cancel的方法进行任务取消，对应的线程任务类已经被封装到了之前的map中

public String stopCron(int id) {ScheduledFuture<?> future = threadMap.get(id);if (future != null) {future.cancel(true);System.out.println("DynamicTask.stopCron()");}return "stopCron";}

以上就是springboot简单的定时任务总结了，详细情况可以去我的git上看看源码哈~~

详情咨询 > https://github.com/mahongbql/ScheduledForDynamicCron

不定期技术文章