Spring Boot使用多线程并发执行定时任务

迈不过友情╰ 2022-05-12 14:04 434阅读 0赞

工程代码示例   : [Spring Boot集成持久化Quartz定时任务管理和界面展示][Spring Boot_Quartz]

### 工程地址  : [https://github.com/tjfy1992/SpringBootQuartz][https_github.com_tjfy1992_SpringBootQuartz] ###

运行方法  
Spring Boot工程已经集成了服务器。右键点击DemoApplication.java -> Run As -> Java Application即可运行工程。默认端口为8080，启动后在浏览器地址栏输入http://localhost:8080/JobManager.html就可以看到效果。

# SpringBoot并发执行定时任务 #

# 开启缓存注解 #

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

# 存在问题 #

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

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

![70][]

# 解决方案 #

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

@Configuration

public class ScheduleConfig implements SchedulingConfigurer \{

@Override

public void configureTasks(ScheduledTaskRegistrar taskRegistrar) \{

taskRegistrar.setScheduler(Executors.newScheduledThreadPool(5));

# 整合成功 #

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

![70 1][]

# 注 #

@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，也很方便。

## 实例: ##

import java.util.Date;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.scheduling.annotation.EnableScheduling;
    import org.springframework.scheduling.annotation.Scheduled;
    import com.isoftstone.common.utils.date.DateUtil;
    
    /**
    * @author leon
    * @createDate 2018年5月9日 下午3:25:26
    * @version v1.0
    * @classRemarks 定时器测试
    */
    @Configuration
    @EnableScheduling
    public class TestTask {
    	
    	private static Logger logger = LoggerFactory.getLogger(TestTask.class);
    	
    	//每隔3秒钟审批一次 (cron 表达式)
    	//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 * * ?
    	//在线生成 http://www.pdtools.net/tools/becron.jsp
    	@Scheduled(cron = "0 */10 * * * ?")
    	public void test(){
    		logger.info("test当前时间为"+DateUtil.dateToStrLong(new Date())+",时间戳:"+System.currentTimeMillis());
    	}
    	
    	@Scheduled(cron = "0 */10 * * * ?")
    	public void test1(){
    		logger.info("test1当前时间为"+DateUtil.dateToStrLong(new Date())+",时间戳:"+System.currentTimeMillis());
    	}
    }

import java.util.concurrent.Executors;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.scheduling.annotation.SchedulingConfigurer;
    import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
    import org.springframework.scheduling.config.ScheduledTaskRegistrar;
    
    /**
     * spring boot 多线程并发定时任务
     * 		所有的任务都在同一个线程池但不同线程中完成
     * @ClassName:：ScheduleConfig 
     * @author leon
     * @createDate	2018年10月15日 下午4:02:38 
     * @version	v1.0
     * @classRemarks TODO
     */
    @Configuration
    public class ScheduleConfig implements SchedulingConfigurer {
    	
    	@Autowired
        ThreadPoolTaskExecutor threadPoolTaskExecutor;
    	
    	@Override
    	public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
    		taskRegistrar.setScheduler(Executors.newScheduledThreadPool(8,threadPoolTaskExecutor));
    	}
    }

[Spring Boot_Quartz]: https://blog.csdn.net/u012907049/article/details/73801122/
[https_github.com_tjfy1992_SpringBootQuartz]: https://github.com/tjfy1992/SpringBootQuartz
[70]: /images/20220504/7196fc3d284049c69ae83b05ecc00523.png
[70 1]: /images/20220504/2e5a1a8295b441e494624ea0c958dede.png