spring boot 多线程定时器

淩亂°似流年 2023-07-20 08:26 16阅读 0赞

## SpringBoot并发执行定时任务 ##

## 1.开启缓存注解 ##

在启动类中添加注解

@EnableScheduling //开启定时任务

## 2.设置定时任务 ##

package com.example.study.timer;
    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 org.springframework.stereotype.Component;
    
    /** * @classRemarks 定时器测试 */
    @Configuration
    @EnableScheduling
    @Component
    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 * * ?
        @Scheduled(cron = "*/5 * * * * ?")
        public void test(){ 
            //System.out.println(("test当前时间为"+MyDateUtils.dateToString(new Date(),"yyyy-MM-dd HH:mm:ss")));
            logger.info("test当前时间为"+MyDateUtils.dateToString(new Date(),"yyyy-MM-dd HH:mm:ss"));
        }
    
        @Scheduled(cron = "*/5 * * * * ?")
        public void test1(){ 
           // System.out.println(("test1当前时间为"+MyDateUtils.dateToString(new Date(),"yyyy-MM-dd")));
            logger.info("test1当前时间为"+MyDateUtils.dateToString(new Date(),"yyyy-MM-dd HH:mm:ss"));
        }
    }

## 发现个问题1 ##

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

## 解决方案 ##

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

@Configuration
    @Component
    public class ScheduleConfig  implements SchedulingConfigurer { 
    
        @Autowired
        ThreadPoolTaskExecutor threadPoolTaskExecutor;
    
        @Override
        public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { 
            taskRegistrar.setScheduler(Executors.newScheduledThreadPool(8,threadPoolTaskExecutor));
        }
    }

## 问题2 ##

在实际操作中,发现启动项目时报错如下:

SpringBoot报错Action: Consider defining a bean named 'threadPoolTaskExecutor' in your configuration

## 解决方案: ##

在启动类中添加配置如下:

//加入如下配置
    	@Bean({ "threadPoolTaskExecutor", "threadPoolTaskExecutor"})
    	public ThreadPoolTaskExecutor threadPoolTaskExecutor() { 
    		return new ThreadPoolTaskExecutor();
    	}

## 整合成功 ##

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

## 输出结果: ##

2020-08-18 16:23:20.002  INFO 12708 --- [lTaskExecutor-4] com.example.study.timer.TestTask         : test当前时间为2020-08-18 16:23:20
    2020-08-18 16:23:20.002  INFO 12708 --- [lTaskExecutor-3] com.example.study.timer.TestTask         : test1当前时间为2020-08-18 16:23:20
    2020-08-18 16:23:25.002  INFO 12708 --- [lTaskExecutor-1] com.example.study.timer.TestTask         : test当前时间为2020-08-18 16:23:25
    2020-08-18 16:23:25.002  INFO 12708 --- [lTaskExecutor-2] com.example.study.timer.TestTask         : test1当前时间为2020-08-18 16:23:25
    2020-08-18 16:23:30.002  INFO 12708 --- [lTaskExecutor-1] com.example.study.timer.TestTask         : test当前时间为2020-08-18 16:23:30
    2020-08-18 16:23:30.002  INFO 12708 --- [lTaskExecutor-6] com.example.study.timer.TestTask         : test1当前时间为2020-08-18 16:23:30
    2020-08-18 16:23:35.002  INFO 12708 --- [lTaskExecutor-3] com.example.study.timer.TestTask         : test1当前时间为2020-08-18 16:23:35
    2020-08-18 16:23:35.002  INFO 12708 --- [lTaskExecutor-1] com.example.study.timer.TestTask         : test当前时间为2020-08-18 16:23:35

## 补充: ##

***@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 * * ?