公司网站制作流程2016,南宁建站热搜,兰州网站制作公司服务电话,陕西省建设厅执业资格注册中心网站报名Q1. springboot怎样创建定时任务#xff1f;
很显然#xff0c;人人都知道#xff0c;Scheduled(cron .....)
Q2. 如上所示创建了定时任务却未能执行是为什么#xff1f;
如果你的cron确定没写错的话 cron表达式是否合法#xff0c;可参考此处#xff0c…Q1. springboot怎样创建定时任务
很显然人人都知道Scheduled(cron .....)
Q2. 如上所示创建了定时任务却未能执行是为什么
如果你的cron确定没写错的话 cron表达式是否合法可参考此处https://tool.lu/crontab/选择Spring表达式。 那么可能是你启动类少了一个注解EnableScheduling 如下图 Q3. 多个定时任务未能严格按照指定的时间执行为什么
比如有4个定时任务分别是每天凌晨的1点整、2点整、3点整、4点整执行 但观察日志发现并不是。 比如1点整开始执行第一个如果会执行很久的话 2点半才开始执行第2个 后面的以此类推都不一定严格按照指定时间。 那么为什么 因为springboot里面的定时任务默认是单线程执行的。后面的定时任务会排队、顺延。 比如Job1执行了1.5hJob2的时间尽管到了但没有线程可用就只能等Job1完成之后才执行。 所以就会出现顺延现象。 Q4. 如何确保定时任务在特定时间执行
这里思路就很简单了多线程即创建一个线程池比如4个线程并且指定使用这个线程池里的线程来做这4个定时任务肯定是足够的。 这样的话就不会依次影响了。 注意,只给定时任务增加Async注解是不够的。 step1初始化线程池
文件1 SchedulerConfig.java
package cn.xxx.starter.config;import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;import javax.annotation.Resource;/*** author * date 2024/4/2 14:22* desc*/
Configuration
public class SchedulerConfig implements SchedulingConfigurer {Resourceprivate ThreadPoolTaskScheduler threadPoolTaskScheduler;Overridepublic void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {scheduledTaskRegistrar.setTaskScheduler(threadPoolTaskScheduler);}
}
文件2 ThreadPoolTaskSchedulerConfig.java
package cn.xxx.starter.config;import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;import java.util.concurrent.Executor;/*** author * date 2024/4/1 17:45* desc*/
Configuration
EnableAsync
public class ThreadPoolTaskSchedulerConfig {private int corePoolSize 4;Beanpublic ThreadPoolTaskScheduler threadPoolTaskScheduler() {ThreadPoolTaskScheduler threadPoolTaskScheduler new ThreadPoolTaskScheduler();//线程池大小为10threadPoolTaskScheduler.setPoolSize(corePoolSize);//设置线程名称前缀threadPoolTaskScheduler.setThreadNamePrefix(AsyncJob-thread-);//关键点: 设置线程池关闭的时候等待所有任务都完成再继续销毁其他的BeanthreadPoolTaskScheduler.setWaitForTasksToCompleteOnShutdown(true);//关键点设置线程池中任务的等待时间如果超过这个时候还没有销毁就强制销毁以确保应用最后能够被关闭而不是阻塞住threadPoolTaskScheduler.setAwaitTerminationSeconds(60 * 60);threadPoolTaskScheduler.initialize();return threadPoolTaskScheduler;}
}step2 ,启动定时任务时指定使用此线程池
XxxxJob.java
package cn.xxx.starter.task.job;import com.alibaba.fastjson.JSON;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;Slf4j
Component
public class Job1{Async(value threadPoolTaskScheduler)Scheduled(cron 0 30 */1 * * ?)public void execute() { try {//......}catch (Exception e){log.error(Job1出错 e {}, stackTrace {} , e.getMessage(), JSON.toJSONString(e.getStackTrace()));}finally {log.info(Job1结束); }}
}
