官方承諾：K60至尊版將會首批升級MIUI 15
全新的MIUI 15今天也有了消息，在官宣了K60至尊版將會搭載天璣9200+處理器和獨(dú)顯芯片X7的同時，Redmi給出了官方承諾，K60至尊重大更新首批升級，會首批推送MIUI 15。也就是說雖然
封裝自定義線程池類是為了在線程執(zhí)行完畢后，我們檢查是否存在異常,如果存在異常，日志打印詳細(xì)異常信息，這樣可以可以幫助我們及時發(fā)現(xiàn)和解決問題。
JDK 默認(rèn)提供的定時調(diào)度線程池類是
ScheduledThreadPoolExecutor，我們只需要繼承它并重寫它的 afterExecute 方法，添加異常日志打印的邏輯。
public class MyScheduledThreadPoolExecutor extends ScheduledThreadPoolExecutor { private Logger log = LoggerFactory.getLogger(MyScheduledThreadPoolExecutor.class); public MyScheduledThreadPoolExecutor(int corePoolSize, ThreadFactory factory) { super(corePoolSize, factory); } @Override protected void afterExecute(Runnable r, Throwable t) { super.afterExecute(r, t); // 打印異常信息 this.printException(r, t); } public void printException(Runnable r, Throwable t) { // 判斷 r 是 Future 實(shí)例并且已經(jīng)完成執(zhí)行的情況下,獲取它的執(zhí)行結(jié)果，并檢查是否有異常拋出 if (t == null && r instanceof Future<?>) { try { Future<?> future = (Future<?>) r; if (future.isDone()) { future.get(); } } catch (CancellationException ce) { t = ce; } catch (ExecutionException ee) { t = ee.getCause(); } catch (InterruptedException ie) { Thread.currentThread().interrupt(); } } if (t != null) { log.error(t.getMessage(), t); } }}創(chuàng)建 ScheduleConfig 類，用于配置定時調(diào)度的執(zhí)行器。代碼概覽如圖所示：
① 創(chuàng)建定時調(diào)度線程池
使用自定義封裝的線程池類，創(chuàng)建線程池，指定線程池創(chuàng)建線程名前綴，并將其設(shè)置成應(yīng)用程序的守護(hù)線程。
@Bean(destroyMethod="shutdown")public ExecutorService taskExecutor() { ThreadFactory factory = new BasicThreadFactory.Builder() .namingPattern("schedule-pool-%d") .daemon(true) .build(); return new MyScheduledThreadPoolExecutor(10, factory);}② 設(shè)置任務(wù)調(diào)度器
實(shí)現(xiàn) SchedulingConfigurer 接口,重寫 configureTasks 方法，允許我們對任務(wù)調(diào)度進(jìn)行自定義配置，這邊我們將我們自定義創(chuàng)建的線程池設(shè)置成任務(wù)調(diào)度器。
@Configurationpublic class ScheduleConfig implements SchedulingConfigurer { @Override public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { // 自定義線程池作為調(diào)度器 taskRegistrar.setScheduler(taskExecutor()); }}在應(yīng)用啟動類上添加注解 `@EnableScheduling`,用于啟用定時調(diào)度，操作如圖所示：
在我們需要定時執(zhí)行的方法上使用相關(guān)注解，標(biāo)記其調(diào)度策略。
①.固定時間執(zhí)行
如果需要在固定的時間點(diǎn)執(zhí)行任務(wù)，可以使用 @Scheduled(cron = "表達(dá)式") 注解來指定 cron 表達(dá)式，如下所示：
@Componentpublic class MyTask { @Scheduled(cron = "0 0 12 * * ?") public void runTask() { // 在每天中午 12 點(diǎn)執(zhí)行任務(wù) }}其中 cron 表達(dá)式使用說明如下表格所示
位數(shù) | 字段 | 允許值 |
1 | 秒 | 0-59 |
2 | 分鐘 | 0-59 |
3 | 小時 | 0-23 |
4 | 日期 | 1-31 |
5 | 月份 | 1-12 或 JAN-DEC |
6 | 星期 | 0-6 或 SUN-SAT，其中 0 和 7 都表示周日 |
7 | 年（可選） | 空白表示任意年，或者指定特定年份，如 2022、2023 |
② 間隔執(zhí)行
如果需要在固定的時間間隔內(nèi)周期性地執(zhí)行任務(wù)，可以使用 @Scheduled(fixedRate = 時間間隔) 或 @Scheduled(fixedDelay = 時間間隔) 注解來指定時間間隔，如下所示：
@Componentpublic class MyTask { @Scheduled(fixedRate = 5000) public void runTask() { // 每 5 秒執(zhí)行一次任務(wù) }}③延遲執(zhí)行
如果需要在應(yīng)用啟動后延遲一段時間后執(zhí)行任務(wù)，可以使用 @Scheduled(initialDelay = 延遲時間) 注解來指定延遲時間，如下所示：
@Componentpublic class MyTask { @Scheduled(initialDelay = 5000, fixedRate = 5000) public void runTask() { // 在應(yīng)用啟動后延遲 5 秒執(zhí)行任務(wù)，之后每 5 秒執(zhí)行一次任務(wù) }}我們就以間隔執(zhí)行進(jìn)行測試，測試方法每3秒執(zhí)行一次。
@Slf4j@Servicepublic class FixedDelayTask { private static int count1 = 1; @Scheduled(fixedDelay = 3000) public void fixedDelay() { log.info(String.format("第%s次執(zhí)行", count1++)); }}
兩次執(zhí)行相隔3秒鐘,并且線程名也是以我們自定義的為前綴。
本文鏈接：http://www.www897cc.com/showinfo-26-75309-0.htmlspringboot-如何配置線程池實(shí)現(xiàn)定時任務(wù)
聲明：本網(wǎng)頁內(nèi)容旨在傳播知識，若有侵權(quán)等問題請及時與本網(wǎng)聯(lián)系，我們將在第一時間刪除處理。郵件：2376512515@qq.com
Copyright ? 2016-2023 天津谷騏科技有限公司 版權(quán)所有 sitemap.xml
違法及侵權(quán)請聯(lián)系：2376512515@qq.com 津ICP備18001702號
津公網(wǎng)安備 12010102000574號