SpringBoot中定時任務@Scheduled的多線程使用詳解

Posted on by

一、@Scheduled註解簡介

@Scheduled是Spring框架中的一個註解，它可以用於配置定時任務，使得方法可以按照規定的時間間隔定時執行。在使用該註解時，我們可以指定任務的執行時間、循環周期、並發數等參數，從而實現定時任務的功能。在Spring Boot中，@Scheduled註解可以直接應用於方法上。

二、@Scheduled的多線程機制

在Spring Boot中，@Scheduled註解是基f於Java的ThreadPoolExecutor和ScheduledThreadPoolExecutor實現的。當我們配置瞭一個定時任務後，Spring Boot會首先創建一個ScheduledThreadPoolExecutor線程池，並將定時任務添加到該線程池中等待執行。然後，在指定的時間到來之後，線程池會為該定時任務分配一個線程來執行。如果該定時任務還未執行完畢，在下一個周期到達時，線程池會為該任務再次分配一個線程來執行。通過這種方式，@Scheduled可以非常方便地實現周期性的定時任務f於Java的ThreadPoolExecutor和ScheduledThreadPoolExecutor實現的。當我們配置瞭一個定時任務後，Spring Boot會首先創建一個ScheduledThreadPoolExecutor線程池，並將定時任務添加到該線程池中等待執行。然後，在指定的時間到來之後，線程池會為該定時任務分配一個線程來執行。如果該定時任務還未執行完畢，在下一個周期到達時，線程池會為該任務再次分配一個線程來執行。通過這種方式，@Scheduled可以非常方便地實現周期性的定時任務。

三、@Scheduled的多線程問題

雖然@Scheduled註解非常便捷，但是它也存在一些多線程的問題，主要體現在以下兩個方面：

1.定時任務未執行完畢時，後續任務可能會受到影響

在使用@Scheduled註解時，我們很容易忽略一個問題：如果定時任務在執行時，下一個周期的任務已經到瞭，那麼後續任務可能會受到影響。例如，我們定義瞭一個間隔時間為5秒的定時任務A，在第1秒時開始執行，需要執行10秒鐘。在第6秒時，定時任務A還沒有結束，此時下一個周期的任務B已經開始等待執行。如果此時線程池中沒有足夠的空閑線程，那麼定時任務B就會被阻塞，無法執行。

2.多個定時任務並發執行可能導致資源競爭

在某些情況下，我們可能需要編寫多個定時任務，這些定時任務可能涉及到共享資源，例如數據庫連接、緩存對象等。當多個定時任務同時執行時，就會存在資源競爭的問題，可能會導致數據錯誤或者系統崩潰。

四、@Scheduled加入線程池來處理定時任務

為瞭避免上述問題，可以將@Scheduled任務交給線程池進行處理。在Spring Boot中，可以通過以下兩種方式來將@Scheduled任務加入線程池：

1.使用@EnableScheduling + @Configuration配置ThreadPoolTaskScheduler

@Configuration
@EnableScheduling
public class TaskSchedulerConfig {
    @Bean
    public TaskScheduler taskScheduler() {
        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
        scheduler.setPoolSize(10);
        scheduler.initialize();
        return scheduler;
    }
}

在上述代碼中，我們通過配置ThreadPoolTaskScheduler來創建一個線程池，並使用@EnableScheduling註解將定時任務開啟。其中，setPoolSize方法可以設置線程池的大小，默認為1。

2.使用ThreadPoolTaskExecutor

@Configuration
@EnableScheduling
public class TaskExecutorConfig {
    @Bean
    public ThreadPoolTaskExecutor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(10);
        executor.setMaxPoolSize(50);
        executor.setQueueCapacity(1000);
        executor.setKeepAliveSeconds(60);
        executor.setThreadNamePrefix("task-executor-");
        return executor;
    }
}

在上述代碼中，我們通過配置ThreadPoolTaskExecutor來創建一個線程池，並使用@EnableScheduling註解將定時任務開啟。其中setCorePoolSize、setMaxPoolSize、setQueueCapacity、setKeepAliveSeconds等方法可以用於配置線程池的大小和任務隊列等參數。

五、@Scheduled詳細分析

在Spring Boot中，@Scheduled註解是基於Java的ThreadPoolExecutor和ScheduledThreadPoolExecutor實現的。當我們配置瞭一個定時任務後，Spring Boot會首先創建一個ScheduledThreadPoolExecutor線程池，並將定時任務添加到該線程池中等待執行。然後，在指定的時間到來之後，線程池會為該定時任務分配一個線程來執行。如果該定時任務還未執行完畢，在下一個周期到達時，線程池會為該任務再次分配一個線程來執行。通過這種方式，@Scheduled可以非常方便地實現周期性的定時任務。

雖然@Scheduled註解非常便捷，但是它也存在一些多線程的問題，主要體現在以下兩個方面：

1. 定時任務未執行完畢時，後續任務可能會受到影響

在使用@Scheduled註解時，我們很容易忽略一個問題：如果定時任務在執行時，下一個周期的任務已經到瞭，那麼後續任務可能會受到影響。例如，我們定義瞭一個間隔時間為5秒的定時任務A，在第1秒時開始執行，需要執行10秒鐘。在第6秒時，定時任務A還沒有結束，此時下一個周期的任務B已經開始等待執行。如果此時線程池中沒有足夠的空閑線程，那麼定時任務B就會被阻塞，無法執行。

解決方案：

針對上述問題，我們可以采用以下兩種方案來解決：

方案一：修改線程池大小

為瞭避免因為線程池中線程數量不足引起的問題，我們可以對線程池進行配置，提高線程池的大小，從而確保有足夠的空閑線程來處理定時任務。

例如，我們可以在application.properties或application.yml或者使用@EnableScheduling + @Configuration來配置線程池大小：

spring.task.scheduling.pool.size=20

2. 多個定時任務並發執行可能導致資源競爭

在某些情況下，我們可能需要編寫多個定時任務，這些定時任務可能涉及到共享資源，例如數據庫連接、緩存對象等。當多個定時任務同時執行時，就會存在資源競爭的問題，可能會導致數據錯誤或者系統崩潰。

解決方案：

為瞭避免由於多個定時任務並發執行導致的資源競爭問題，我們可以采用以下兩種方案來解決：

方案一：使用鎖機制

鎖機制是一種常見的解決多線程並發訪問共享資源的方式。在Java中，我們可以使用synchronized關鍵字或者Lock接口來實現鎖機制。

例如，下面是一個使用synchronized關鍵字實現鎖機制的示例：

private static Object lockObj = new Object();

@Scheduled(fixedDelay = 1000)
public void doSomething(){
    synchronized(lockObj){
        // 定時任務要執行的內容
    }
}

在上述代碼中，我們定義瞭一個靜態對象lockObj，用來保護共享資源。在定時任務執行時，我們使用synchronized關鍵字對lockObj進行加鎖，從而確保多個定時任務不能同時訪問共享資源。

方案二：使用分佈式鎖

除瞭使用傳統的鎖機制外，還可以使用分佈式鎖來解決資源競爭問題。分佈式鎖是一種基於分佈式系統的鎖機制，它可以不依賴於單個JVM實例，從而能夠保證多個定時任務之間的資源訪問不會沖突。

在Java開發中，我們可以使用ZooKeeper、Redis等分佈式系統來實現分佈式鎖機制。例如，使用Redis實現分佈式鎖的示例代碼如下：

@Autowired
private RedisTemplate redisTemplate;

@Scheduled(fixedDelay = 1000)
public void doSomething(){
    String lockKey = "lock:key";
    String value = UUID.randomUUID().toString();
    Boolean result = redisTemplate.opsForValue().setIfAbsent(lockKey, value, 5L, TimeUnit.SECONDS);
    if(result){
        try{
            // 定時任務要執行的內容
        }finally{
            redisTemplate.delete(lockKey);
        }
    }
}

在上述代碼中，我們使用Redis實現瞭分佈式鎖機制。具體而言，我們在定時任務執行時，首先向Redis中寫入一個鍵值對，然後檢查是否成功寫入。如果成功寫入，則表示當前定時任務獲得瞭鎖，可以執行接下來的操作。在定時任務執行完畢後，我們再從Redis中刪除該鍵值對，釋放鎖資源。

六、總結

通過以上的分析，我們可以瞭解到：雖然@Scheduled註解能夠非常方便地實現定時任務的功能，但是它也存在一些多線程的問題。為此，需要註意到這些問題，並采取相應的措施來避免它們的出現。在實際開發中，可以結合使用線程池、異步線程池、鎖機制、分佈式鎖等方式，達到最佳的效果。

到此這篇關於SpringBoot中定時任務@Scheduled的多線程使用詳解的文章就介紹到這瞭,更多相關SpringBoot定時任務@Scheduled內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！

推薦閱讀：