人才市场招聘网站,定陶区城乡建设局网站,小制作小发明手工初中,长沙关键词优化平台在项目我们会有很多需要在某一特定时刻自动触发某一时间的需求#xff0c;例如我们提交订单但未支付的超过一定时间后需要自动取消订单。
定时任务实现的几种方式#xff1a; Timer#xff1a;java自带的java.util.Timer类#xff0c;使用这种方式允许你调度一个java.util…在项目我们会有很多需要在某一特定时刻自动触发某一时间的需求例如我们提交订单但未支付的超过一定时间后需要自动取消订单。
定时任务实现的几种方式 Timerjava自带的java.util.Timer类使用这种方式允许你调度一个java.util.TimerTask任务。这种方式可以让你的程序按照某一个频度执行但不能在指定时间运行。一般用的较少。 ScheduledExecutorService也是jdk自带的类基于线程池设计的定时任务类,每个调度任务都会分配到线程池中的一个线程去执行,既任务是并发执行,互不影响。 Spring TaskSpring3.0以后自带的task相当于一个轻量级的Quartz但其使用起来比Quartz简单很多。 Quartz一个功能比较强大的的调度器可以让你的程序在指定时间执行也可以按照某一个频度执行配置起来稍显复杂。
下面我们看一下如何通过Scheduled实现SpringBoot 的定时任务。 1. 启用定时任务
在springboot主类增加注解EnableScheduling启用定时任务
import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.scheduling.annotation.EnableScheduling;
SpringBootApplicationEnableSchedulingpublic class ScheduledApplication {public static void main(String[] args) { SpringApplication.run(SpringBootScheduledApplication.class, args); }}
2.创建任务类
Slf4jComponentpublic class ScheduledService { Scheduled(cron 0/20 * * * * *) public void scheduled(){ log.info(1使用cron {},System.currentTimeMillis()); } Scheduled(fixedRate 3000) public void scheduled1() { log.info(2使用fixedRate{}, System.currentTimeMillis()); } Scheduled(fixedDelay 3000) public void scheduled2() { log.info(3fixedDelay{},System.currentTimeMillis()); }}
默认为单线程可以看到三个定时任务都已经执行并且使同一个线程中串行执行如果只有一个定时任务这样做肯定没问题当定时任务增多如果一个任务卡死会导致其他任务也无法执行。
3.实现多线程任务
3.1 添加配置类并启用异步事件
ConfigurationEnableAsyncpublic class ScheduledAsyncConfig {
private int corePoolSize 20;private int maxPoolSize 500;private int queueCapacity 20;
Beanpublic Executor taskExecutor() {ThreadPoolTaskExecutor executor new ThreadPoolTaskExecutor();executor.setCorePoolSize(corePoolSize);executor.setMaxPoolSize(maxPoolSize);executor.setQueueCapacity(queueCapacity);executor.initialize();return executor;}}
3.2修改2.中的定时任务的类或者方法上添加Async
Slf4jComponentAsyncpublic class ScheduledService { Scheduled(cron 0/20 * * * * *) public void scheduled(){ log.info(1使用cron {},System.currentTimeMillis()); } Scheduled(fixedRate 3000) public void scheduled1() { log.info(2使用fixedRate{}, System.currentTimeMillis()); } Scheduled(fixedDelay 3000) public void scheduled2() { log.info(3fixedDelay{},System.currentTimeMillis()); }}
