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

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

這些操作有2個，如下所示。

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

答案是會。

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

也就是說，我們不需要修改上面這個ShareDataBySend類，而是新注冊一個線程池任務(wù)調(diào)度器，系統(tǒ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 個任務(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)啟動的時候，Spring Boot會將帶有@Config注解的類型實(shí)例化到容器中，因此SchedulerConfig 配置的 ThreadPoolTaskScheduler 被初始化。

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

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

2、原ShareDataBySend類

不需要作任何修改

總結(jié)

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

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

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

最新評論