springboot使用定時器@Scheduled不管用的解決
使用定時器@Scheduled不管用
如果是一開始就不能用就是沒寫@EnableScheduling注解,如果是用著用著不管用了 是因為@Scheduled是單線程,有定時器在工作或者沒有運行完畢,所以造成了線程堵塞所以導(dǎo)致下一個定時器不能運行增加一個方法類
package com.llt; import org.springframework.boot.autoconfigure.batch.BatchProperties; import org.springframework.context.annotation.Configuration; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.scheduling.annotation.SchedulingConfigurer; import org.springframework.scheduling.config.ScheduledTaskRegistrar; import java.lang.reflect.Method; import java.util.concurrent.Executors; @Configuration public class ScheduleConfig implements SchedulingConfigurer { @Override public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { Method[] methods = BatchProperties.Job.class.getMethods(); int defaultPoolSize = 3; int corePoolSize = 0; if (methods != null && methods.length > 0) { for (Method method : methods) { Scheduled annotation = method.getAnnotation(Scheduled.class); if (annotation != null) { corePoolSize++; } } if (defaultPoolSize > corePoolSize) corePoolSize = defaultPoolSize; } taskRegistrar.setScheduler(Executors.newScheduledThreadPool(corePoolSize)); } }
就好了!
多個@Scheduled定時器不執(zhí)行
最近項目中經(jīng)常有用到@Scheduled注解,在內(nèi)測時由于數(shù)據(jù)量小(沒有進(jìn)行壓力測)所以每個線程執(zhí)行都很快,但線上后發(fā)現(xiàn)部分功能無法使用,最后定位是部分的定時器沒有執(zhí)行,后查閱資料和Springboot源碼后
ScheduledTaskRegistrar在啟動時,如果沒有指定線程池的大小,默認(rèn)會創(chuàng)建核心線程數(shù)為1的默認(rèn)線程池,故而當(dāng)項目中出現(xiàn)多個@Scheduled線程時,只能一個個的執(zhí)行,從而導(dǎo)致個別線程執(zhí)行時間過長(或長期執(zhí)行)時,其他定時器不能按照指定的規(guī)則進(jìn)行執(zhí)行。
解決方法
1.在項目初始化時指定其執(zhí)行線程池的大小
import org.springframework.boot.autoconfigure.batch.BatchProperties; import org.springframework.context.annotation.Configuration; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.scheduling.annotation.SchedulingConfigurer; import org.springframework.scheduling.config.ScheduledTaskRegistrar; import java.lang.reflect.Method; import java.util.Arrays; import java.util.Objects; import java.util.concurrent.ScheduledThreadPoolExecutor; import java.util.concurrent.atomic.AtomicInteger; /** * 程序名 : ScheduledTaskConfiguration * 建立日期: 2021-02-23 9:33 * 模塊 : Scheduled任務(wù)線程池設(shè)置 * 描述 : 讀取項目中使用了@Scheduled注解的方法,默認(rèn)所有方法在項目創(chuàng)建時都需要按照設(shè)定的規(guī)則執(zhí)行 * 備注 : //TODO * <p> * 修改歷史 * 序號 日期 修改人 修改原因 */ @Configuration public class ScheduledTaskConfiguration implements SchedulingConfigurer { @Override public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { Method[] methods = BatchProperties.Job.class.getMethods(); final AtomicInteger corePoolSize = new AtomicInteger(); if (Objects.nonNull(methods) && methods.length > 0) { Arrays.stream(methods).forEach(method -> { final Scheduled annotation = method.getAnnotation(Scheduled.class); if (Objects.nonNull(annotation)) { corePoolSize.incrementAndGet(); } }); } ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(corePoolSize.get()); taskRegistrar.setScheduler(executor); } }
2.將定時器設(shè)置為異步線程
/** 異步線程 定時器延遲1秒啟動,每距上一次執(zhí)行完成后間隔3秒執(zhí)行一次 */ @Async("taskExecutor") @Scheduled(initialDelay = 1000L, fixedDelay = 3000L) public void test(){ System.out.println("---"+System.currentTimeMillis()); //業(yè)務(wù)內(nèi)容 }
以上為個人經(jīng)驗,希望能給大家一個參考,也希望大家多多支持腳本之家。
相關(guān)文章
解析整合mybatis-spring需要的maven依賴配置問題
這篇文章主要介紹了整合mybatis-spring需要的maven依賴配置問題,創(chuàng)建Maven項目,導(dǎo)入相關(guān)jar包,文中還給大家提到了,解決maven靜態(tài)資源約定大于習(xí)慣問題,本文給大家介紹的非常詳細(xì),需要的朋友參考下吧2021-11-11

spring mvc常用注解_動力節(jié)點Java學(xué)院整理
FeignClient服務(wù)器拋出異??蛻舳颂幚矸桨?/a>

Spring中如何獲取request的方法匯總及其線程安全性分析