Springboot多线程下调度任务的执行

た入场券 2023-10-06 12:42 36阅读 0赞

#### Springboot多线程下调度任务的执行 ####

*  多线程下多个调度任务的执行
 *   *  调度代码实现
     *  线程池代码实现
     *  执行结果
 *  单个调度任务多线程下的执行
 *   *  调度代码实现
     *  线程池代码实现
     *  执行结果

## 多线程下多个调度任务的执行 ##

在springboot框架中 提供注解@Scheduled 实现一个任务的定时调度执行，多个调度任务在同一个时间段内执行时为了提高处理业务效率，引入多线程执行，以下是如何实现多个调度任务下的多线程处理

\*\*\***需要注意：项目启动后 在同一个时间片内多个调度任务会从线程池中获取多个线程并行处理**

### 调度代码实现 ###

@Scheduled(cron = "0/10 * * * * ?")
        public void testA() {
        
        	logger.info("testA start");
        }
        
        @Scheduled(cron = "0/10 * * * * ?")
        public void testB() {
        
        	logger.info("testB start");
        }

### 线程池代码实现 ###

@Configuration
    //所有的调度方法任务都放在一个线程池中，其中一个调度方法对应一个线程
    public class ScheduleConfig  implements SchedulingConfigurer{
        
    
    	@Value("${schedule.ThreadCount}")
    	private Integer scheduleThreadCount;
    
    	@Override
    	public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        
    		// 设定一个长度scheduleThreadCount的定时任务线程池
    		taskRegistrar.setScheduler(Executors.newScheduledThreadPool(scheduleThreadCount));
    	}
    }

### 执行结果 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0FpTWFpU2hhbkh1SGFp_size_16_color_FFFFFF_t_70]

## 单个调度任务多线程下的执行 ##

通过上面的代码示例大家对多个调度任务多线程的处理已经了然于胸，但是实际业务场景还有出现同一个调度任务需要多线程支持的情况，比如 ：在同一个调度任务内 需要处理多个批次的业务数据，且多个批次数据没有前后依赖关系，这种情况下 如果单线程的话就会容易因为一个批次的处理滞后影响后续批次的业务逻辑处理，那怎么提升多个批次的处理效率呢？大家试想下， 如果让这多个批次的数据在多个线程下处理， 是不是就会得到指数级的性能提升，具体代码实现可以参考如下：

### 调度代码实现 ###

\*\*\*需要注意的是@Async注解

@Scheduled(cron = "0/10 * * * * ?")
        @Async("schedulerTaskExecutor")
        public void testA() {
        
        	logger.info("testA start");
        	try {
        
    			Thread.sleep(100000);
    			logger.info("testA1 start....");
    		} catch (InterruptedException e) {
        
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
        	
        }
        
        @Scheduled(cron = "0/10 * * * * ?")
        public void testB() {
        
        	logger.info("testB start");
        }

### 线程池代码实现 ###

@Configuration
    //所有的定时任务都放在一个线程池中，定时任务启动时使用不同的线程。
    public class ScheduleConfig {
        
    
    	@Value("${schedule.ThreadCount}")
    	private Integer scheduleThreadCount;
    
    	@Bean("schedulerTaskExecutor")
    	public TaskScheduler taskScheduler() {
        
    		ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
    		taskScheduler.setPoolSize(scheduleThreadCount);
    		taskScheduler.initialize();
    		return taskScheduler;
    	}
    	 
    	
    }

### 执行结果 ###

![在这里插入图片描述][20200709174923633.png]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0FpTWFpU2hhbkh1SGFp_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200709173603883.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0FpTWFpU2hhbkh1SGFp,size_16,color_FFFFFF,t_70
[20200709174923633.png]: https://img-blog.csdnimg.cn/20200709174923633.png