spring-boot | 多线程并发定时任务

Posted by wotrd on 08-09,2019

spring-boot | 多线程并发定时任务

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

开启缓存注解

@SpringBootApplication
@EnableScheduling //开启定时任务
public class Application {
    public static void main(String[] args) {
       SpringApplication.run(Application.class, args);
    }
}

编写定时任务

@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秒执行一次");
    }
}

任务完成

启动项目,查看控制台打印信息,发现定时任务已经生效。spring boot 和Scheduled整合完毕。

s_sch_1

(1)线程阻赛

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

@Scheduled(cron="0/1 * * * * ? ")   //每1秒执行一次 
public void testCron1() {
   DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");  
    logger.info(sdf.format(new Date())+"*********每1秒执行一次");
}

@Scheduled(cron="0/2 * * * * ? ")   //每2秒执行一次 
public void testCron2() {
   DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");  
    logger.info(sdf.format(new Date())+"*********每2秒执行一次");
}

@Scheduled(cron="0/3 * * * * ? ")   //每3秒执行一次 
public void testCron3() {
   DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");  
    logger.info(sdf.format(new Date())+"*********每3秒执行一次");
}

@Scheduled(cron="0/4 * * * * ? ")   //每4秒执行一次 
public void testCron4() {
   DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");  
    logger.info(sdf.format(new Date())+"*********每4秒执行一次");
}   

s_ch_2

解决方案

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

@Configuration
public class ScheduleConfig implements SchedulingConfigurer {
	@Override
	public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
    		taskRegistrar.setScheduler(Executors.newScheduledThreadPool(5));
	}
}

整合成功

这样就完成了多线程并发的配置?我们启动项目通过控制台输出信息验证一下结果,最后发现所有的任务都在同一个线程池但不同线程中完成,说明这个方案完全可行,这样,我们就完成了spring boot 多线程并发定时任务。

s_ch_3

(2)更新系统时间和cron配置关闭

更新系统时间和cron配置后,定时器会关闭。此时,需要重启服务。

@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:时区,默认为当前时区,一般没有用到。

Cron表达式范例:

每隔5秒执行一次:*/5 * * * * ? 每隔1分钟执行一次:0 */1 * * * ? 每天23点执行一次:0 0 23 * * ? 每天凌晨1点执行一次:0 0 1 * * ? 每月1号凌晨1点执行一次:0 0 1 1 * ? 每月最后一天23点执行一次:0 0 23 L * ? 每周星期天凌晨1点实行一次:0 0 1 ? * L 在26分、29分、33分执行一次:0 26,29,33 * * * ? 每天的0点、13点、18点、21点都执行一次:0 0 0,13,18,21 * * ?

其实不会Cron表达式也不用担心,网上有好多在线Cron生成器,我们完全可以通过在线生成器生成符合要求的cron,也很方便。 原文地址

自己实现

Spring Schedule底层使用的是ThreadPoolTaskScheduler。因此,我们可以实现这个接口,自定义定时器。

@RestController
@Component
public class DynamicTask {
    @Autowired
    private ThreadPoolTaskScheduler threadPoolTaskScheduler;
    private ScheduledFuture<?> future;

    @Bean
    public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
   	return new ThreadPoolTaskScheduler();
    }
    @RequestMapping("/startCron")
    public String startCron() {
       future = threadPoolTaskScheduler.schedule(new MyRunnable(), new CronTrigger("0/5 * * * * *"));
       System.out.println("DynamicTask.startCron()");
       return "startCron";
    }

    @RequestMapping("/stopCron")
    public String stopCron() {
       if (future != null) {
           future.cancel(true);
       }
       System.out.println("DynamicTask.stopCron()");
       return "stopCron";
    }

    @RequestMapping("/changeCron10")
    public String startCron10() {
       stopCron();// 先停止,在开启.
       future = threadPoolTaskScheduler.schedule(new MyRunnable(), new CronTrigger("*/10 * * * * *"));
       System.out.println("DynamicTask.startCron10()");
       return "changeCron10";
    }

    private class MyRunnable implements Runnable {
       @Override
       public void run() {
    	   System.out.println("DynamicTask.MyRunnable.run()," + new Date());
       }
    }
}

有问题,请留言!