目录
- 多个@Scheduled定时任务执行时个别不执行
- 原因
- 解决办法
- @Scheduled多定时任务,重叠执行
- 总结
多个@Scheduled定时任务执行时个别不执行
原因
项目在启动时,如果没有指定线程池的大小,默认会创建核心线程数为1的默认线程池,故而当项目中出现多个@Scheduled线程时,只能一个个的执行,从而导致个别线程执行时间过长(或长期执行)时,其他定时器不能按照指定的规则进行执行。
解决办法
1、配置执行线程池的大小
spring.task.scheduling.pool.size=10
2.将定时器设置为异步线程
/** 异步线程 定时器延迟1秒启动,每距上一次执行完成后间隔3秒执行一次 */ @Async(“taskExecutor”) @Scheduled(initialDelay = 1000L, fixedDelay = 3000L) public void test(){System.out.println(“—”+System.currentTimeMillis());//业务内容 }
@Scheduled多定时任务,重叠执行
@Scheduled如果有两个定时任务,定时任务重复时,只有一个可以执行。如下
import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import Java.time.LocalDateTime; @Component public class MyScheduled { @Scheduled(cron = "0/5 * * * * ?") public void execute1(){ String curName = Thread.currentThread().getName() ; System.ouandroidt.println("当前时间:"+LocalDateTime.now()+" 任务execute1对应的线程名: "+curName); try { Thread.sleep(1000); } catch (Exception e) { e.printStackTrace(); } } @Scheduled(cron = "0/5 * * * * ?") public void execute2(){ String curName = Thread.currentThread().getName() ; System.out.println("当前时间:"+LocalDateTime.now()+" 任务execute2对应的线程名: "+curName); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } }
通过执行可以看到,打印线程名称为同一个。即如果不手动指定线程池,则默认启动单线程,进行执行定时任务。
如果想要多个定时任务重叠执行,需要手动指定线程池,如下
import org.springframework.context.annotation.Bean; import org.springframework.scheduling.TaskScheduler; import org.springframework.scheduling.annotation.EnableScheduling; import org.springframework.scheduling.annotation.Scheduled; import org.sprphpingframework.scheduling.concurrent.ThreadPoolTaskScheduler; import org.springframework.stereotype.Component; import java.time.LocalDateTime; @Component @EnableScheduling public class MyScheduled { @Bean public TaskScheduler taskScheduler() { ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler(); taskScheduler.setPoolSize(50); return taskScheduler; } @Scheduled(cron = "0/5 * * * * ?") public void execute1(){ String curName = Thread.currentThread().getName() ; System.out.println("当前时间:"+LocalDateTime.now()+" 任务execute1对应的线程名: "+curName); try { 编程客栈 Threa编程d.sleep(1000); } catch (Exception e) { e.printStackTrace(); } } @Scheduled(cron = "0/5 * * * * ?") public void execute2(){ String curName = Thread.currentTphphread().getName() ; System.out.println("当前时间:"+LocalDateTime.now()+" 任务execute2对应的线程名: "+curName); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } }
此时,多个定时任务,是不通的线程执行,同时,定时任务可以重叠执行。
总结
以上为个人经验,希望能给大家一个参考,也希望大家多多支持编程客栈(www.devze.com)。
精彩评论