springboot使用線程池(ThreadPoolTaskExecutor)示例

代碼倉庫:gitee

線程池創建

@Configuration
@EnableAsync
public class TaskPoolConfig {

    @Bean("syncExecutorPool")
    public Executor taskExecutor() {
        ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
        // 核心池大小
        taskExecutor.setCorePoolSize(5);
        // 最大線程數
        taskExecutor.setMaxPoolSize(10);
        // 隊列程度
        taskExecutor.setQueueCapacity(100);
        // 線程空閑時間
        taskExecutor.setKeepAliveSeconds(60);
        // 線程前綴名稱
        taskExecutor.setThreadNamePrefix("syncExecutor--");
        // 該方法用來設置 線程池關閉 的時候 等待 所有任務都完成後,再繼續 銷毀 其他的 Bean,
        // 這樣這些 異步任務 的 銷毀 就會先於 數據庫連接池對象 的銷毀。
        taskExecutor.setWaitForTasksToCompleteOnShutdown(true);
        // 任務的等待時間 如果超過這個時間還沒有銷毀就 強制銷毀,以確保應用最後能夠被關閉,而不是阻塞住。
        taskExecutor.setAwaitTerminationSeconds(60);
        // 線程不夠用時由調用的線程處理該任務
        taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        return taskExecutor;
    }
}

線程池參數

核心線程數量:CorePoolSize
看業務場景設置(我通常設置為CPU核心*1)

最大線程數量:MaxPoolSize
當核心線程數量都在使用狀態時,會調用最大線程數量裡的線程,使用的總線程不會超過最大線程數量,其餘則等待(我通常設置為CPU核心*2)

隊列程度:QueueCapacity
線程隊列的大小

線程空閑時間:KeepAliveSeconds

線程前綴名稱:ThreadNamePrefix

停機策略:WaitForTasksToCompleteOnShutdown
該方法用來設置 線程池關閉 的時候 等待 所有任務都完成後,再繼續 銷毀 其他的 Bean,這樣這些 異步任務 的 銷毀 就會先於 數據庫連接池對象 的銷毀。

任務的等待時間:AwaitTerminationSeconds
任務的等待時間 如果超過這個時間還沒有銷毀就 強制銷毀,以確保應用最後能夠被關閉,而不是阻塞住

拒接策略:RejectedExecutionHandler
線程不夠用時由調用的線程處理該任務

線程池測試1(核心線程數量)

結果:線程池的核心線程數量輪訓執行

線程池測試2(當核心線程數量和最大線程數量不夠時)

隨機睡眠0-10000毫秒
new Random().nextInt(10000)

結果:

當5個核心線程數量不夠用時,使用最大線程數量裡的線程
當最大線程數量不夠用時,使用主線程執行該任務

// 線程不夠用時由調用的線程處理該任務
taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());

總結

到此這篇關於springboot使用線程池(ThreadPoolTaskExecutor)示例的文章就介紹到這瞭,更多相關springboot線程池內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet!

推薦閱讀: