快捷導(dǎo)航

老生常談spring?boot中的定時(shí)任務(wù)

更新時(shí)間：2024年05月21日 09:29:29 作者：Hanyta

SpringBoot中的定時(shí)任務(wù)主要通過@Scheduled注解以及SchedulingConfigurer接口實(shí)現(xiàn),本文給大家介紹spring?boot中的定時(shí)任務(wù),感興趣的朋友跟隨小編一起看看吧

SpringBoot中的定時(shí)任務(wù)主要通過@Scheduled注解以及SchedulingConfigurer接口實(shí)現(xiàn)。
@Scheduled注解是Spring提供的一個注解，用于標(biāo)記方法作為定時(shí)任務(wù)執(zhí)行:配置方法在指定的時(shí)間間隔或時(shí)間點(diǎn)執(zhí)行，實(shí)現(xiàn)各種定時(shí)任務(wù)需求。

//在你需要定時(shí)的方法上加上@Scheduled注解，并用corn表達(dá)式指定如何定時(shí)，下式表達(dá)了每隔15秒執(zhí)行一次方法
@Scheduled(cron = "*/15 * * * * ?")
public void hello() {
    System.out.println("hello執(zhí)行了");
}

但是要記得在啟動類上開啟定時(shí)功能：@EnableScheduling // 開啟定時(shí)任務(wù)功能
@Scheduled任務(wù)在單線程環(huán)境下執(zhí)行，可能出現(xiàn)任務(wù)堆積的情況，尤其在任務(wù)量大或任務(wù)執(zhí)行時(shí)間長的情況下，而且這些任務(wù)可能會變得混亂和難以管理。定時(shí)任務(wù)的配置分散在各個任務(wù)方法中，不利于統(tǒng)一管理和維護(hù)。對于需要根據(jù)動態(tài)條件創(chuàng)建或銷毀定時(shí)任務(wù)的情況，@Scheduled注解也無法滿足需求。
使用SchedulingConfigurer接口來動態(tài)地創(chuàng)建和管理定時(shí)任務(wù)。通過實(shí)現(xiàn) SchedulingConfigurer 接口，我們可以編寫代碼來動態(tài)地注冊和管理定時(shí)任務(wù)，從而實(shí)現(xiàn)靈活的任務(wù)調(diào)度需求。SchedulingConfigurer 接口是 Spring 提供的一個用于定時(shí)任務(wù)配置的擴(kuò)展接口，它允許開發(fā)人員更細(xì)粒度地控制定時(shí)任務(wù)的執(zhí)行。通過實(shí)現(xiàn)SchedulingConfigurer接口，可以自定義任務(wù)調(diào)度器（TaskScheduler），配置線程池等參數(shù)，以滿足不同場景下的定時(shí)任務(wù)需求。

@Configuration  
@EnableScheduling  
public class CustomSchedulingConfig implements SchedulingConfigurer {
	@Override  
	public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
		// 定時(shí)任務(wù)邏輯
	}
}

通過實(shí)現(xiàn)SchedulingConfigurer接口，重寫configureTasks方法，自定義任務(wù)調(diào)度器的配置。此外我們還可以配置線程池，用于控制定時(shí)任務(wù)執(zhí)行時(shí)的線程數(shù)量、并發(fā)性等參數(shù)。

@Bean(destroyMethod = "shutdown")  
public ThreadPoolTaskScheduler threadPoolTaskScheduler() {  
    ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();  
    scheduler.setPoolSize(5); // 設(shè)置線程池大小  
    scheduler.setThreadNamePrefix("scheduled-task-"); // 設(shè)置線程名稱前綴  
    scheduler.setAwaitTerminationSeconds(60); // 設(shè)置終止等待時(shí)間  
	// 設(shè)置處理拒絕執(zhí)行的任務(wù)異常
	scheduler.setRejectedExecutionHandler((r, executor) -> log.error("Task rejected", r));
	// 處理定時(shí)任務(wù)執(zhí)行過程中拋出的未捕獲異常
	scheduler.setErrorHandler(e -> log.error("Error in scheduled task", e));
    return scheduler;  
}
//然后將自定義的ThreadPoolTaskScheduler設(shè)置到ScheduledTaskRegistrar中去：
@Override  
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
	// 定時(shí)任務(wù)邏輯
	taskRegistrar.setTaskScheduler(threadPoolTaskScheduler());
}
//通過SchedulingConfigurer接口，可以更靈活地配置任務(wù)調(diào)度器和定時(shí)任務(wù)的執(zhí)行規(guī)則，比如動態(tài)注冊定時(shí)任務(wù)、動態(tài)修改任務(wù)執(zhí)行規(guī)則等。

到此這篇關(guān)于spring boot中的定時(shí)任務(wù)的文章就介紹到這了,更多相關(guān)spring boot定時(shí)任務(wù)內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: