快捷導(dǎo)航

SpringBoot項(xiàng)目如何使用多線程執(zhí)行定時(shí)任務(wù)

更新時(shí)間：2025年01月14日 09:34:01 作者：左直拳

在SpringBoot項(xiàng)目中使用多線程執(zhí)行定時(shí)任務(wù),可以避免一個(gè)耗時(shí)任務(wù)影響其他任務(wù),通過配置線程池任務(wù)調(diào)度器,Spring會(huì)自動(dòng)使用多線程執(zhí)行定時(shí)任務(wù)

SpringBoot使用多線程執(zhí)行定時(shí)任務(wù)

我在一個(gè)Spring Boot項(xiàng)目中，采用定時(shí)器執(zhí)行一些操作，比如10秒就發(fā)送一次數(shù)據(jù)。

這些操作有2個(gè)，如下所示。

我就想，雖然這兩個(gè)操作各自指定了時(shí)間頻率，但如果其中一個(gè)操作非常耗時(shí)，會(huì)不會(huì)影響其他操作呢？

答案是會(huì)。

@Service
public class ShareDataBySend {
    @Autowired
    SendDataService sendDataService;

	//操作1
    @Scheduled(fixedRateString = "${sff.interval}")  // 每 * 秒執(zhí)行一次
    private void send() {
        sendDataService.sendThem();
    }

	//操作2
    @Scheduled(fixedRateString = "${sff.interval}")  // 每 * 秒執(zhí)行一次
    private void send2() {
        sendDataService.sendNce();
    }
}

怎么辦呢？AI告訴我，引入多線程。

引入多線程

上面代碼中，使用了注解@Scheduled。這個(gè)注解告訴 Spring ，它需要定期執(zhí)行標(biāo)注的方法。@Scheduled依賴于 Spring 的任務(wù)調(diào)度機(jī)制，默認(rèn)使用一個(gè)單線程的任務(wù)調(diào)度器執(zhí)行任務(wù)。如果沒有顯式地配置線程池，所有的定時(shí)任務(wù)都會(huì)在同一個(gè)線程中按順序執(zhí)行。然而，當(dāng)我們配置一個(gè)線程池任務(wù)調(diào)度器時(shí)，Spring 會(huì)自動(dòng)使用這個(gè)調(diào)度器，這樣每個(gè)定時(shí)任務(wù)（如 send() 和 send2()）就會(huì)在不同的線程中并發(fā)執(zhí)行。

也就是說，我們不需要修改上面這個(gè)ShareDataBySend類，而是新注冊(cè)一個(gè)線程池任務(wù)調(diào)度器，系統(tǒng)就會(huì)自動(dòng)改用多線程。這一切，都源自于Spring Boot框架的本身機(jī)制。

代碼示例

1、新增線程池任務(wù)調(diào)度器配置類

import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;

@Configuration
public class SchedulerConfig implements SchedulingConfigurer {
    /**
     * 我們將默認(rèn)的單線程調(diào)度器替換成了 ThreadPoolTaskScheduler，并設(shè)置了線程池大?。ɡ?10）。
     * 這意味著多達(dá) 10 個(gè)任務(wù)可以并發(fā)執(zhí)行。
     */
    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
        taskScheduler.setPoolSize(10);  // 設(shè)置線程池大小，可根據(jù)需要調(diào)整
        taskScheduler.initialize();
        taskRegistrar.setTaskScheduler(taskScheduler);
    }
}

在系統(tǒng)啟動(dòng)的時(shí)候，Spring Boot會(huì)將帶有@Config注解的類型實(shí)例化到容器中，因此SchedulerConfig 配置的 ThreadPoolTaskScheduler 被初始化。

當(dāng)定時(shí)任務(wù)觸發(fā)時(shí)（根據(jù) @Scheduled 的定義），任務(wù)被提交給 ThreadPoolTaskScheduler 處理。

如果有多個(gè)任務(wù)，它們會(huì)被分配到線程池中的不同線程上執(zhí)行，從而實(shí)現(xiàn)并發(fā)。

2、原ShareDataBySend類

不需要作任何修改

總結(jié)

我用java也有好幾年了。其實(shí)一直都是在用Spring Boot。Spring Boot是一個(gè)java開發(fā)框架，但我感覺Spring Boot已經(jīng)足夠優(yōu)秀和方便，對(duì)于我來說，Spring Boot == Java。當(dāng)然了，本質(zhì)上，Spring Boot可以算是J2EE的一個(gè)流派，但青出于藍(lán)。

另外，我就相同的問題，分別問通義千問和chatGPT，前者給出的方案不僅繁瑣，而且有錯(cuò)誤。這或許不是模型的問題，而是模型訓(xùn)練的材料有問題。也就是說，也許中文世界中，編程問題的答案質(zhì)量，與老外相比，不在一個(gè)檔次內(nèi)。

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: