快捷導(dǎo)航

springboot使用線程池(ThreadPoolTaskExecutor)示例

更新時(shí)間：2022年01月23日 17:25:36 作者：返回主頁(yè)云深小麥

大家好，本篇文章主要講的是springboot使用線程池（ThreadPoolTaskExecutor）示例，感興趣的同學(xué)趕快來(lái)看一看吧，對(duì)你有幫助的話記得收藏一下，方便下次瀏覽

線程池創(chuàng)建

@Configuration
@EnableAsync
public class TaskPoolConfig {

    @Bean("syncExecutorPool")
    public Executor taskExecutor() {
        ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
        // 核心池大小
        taskExecutor.setCorePoolSize(5);
        // 最大線程數(shù)
        taskExecutor.setMaxPoolSize(10);
        // 隊(duì)列程度
        taskExecutor.setQueueCapacity(100);
        // 線程空閑時(shí)間
        taskExecutor.setKeepAliveSeconds(60);
        // 線程前綴名稱
        taskExecutor.setThreadNamePrefix("syncExecutor--");
        // 該方法用來(lái)設(shè)置 線程池關(guān)閉 的時(shí)候 等待 所有任務(wù)都完成后，再繼續(xù) 銷毀 其他的 Bean，
        // 這樣這些 異步任務(wù) 的 銷毀 就會(huì)先于 數(shù)據(jù)庫(kù)連接池對(duì)象 的銷毀。
        taskExecutor.setWaitForTasksToCompleteOnShutdown(true);
        // 任務(wù)的等待時(shí)間 如果超過(guò)這個(gè)時(shí)間還沒(méi)有銷毀就 強(qiáng)制銷毀，以確保應(yīng)用最后能夠被關(guān)閉，而不是阻塞住。
        taskExecutor.setAwaitTerminationSeconds(60);
        // 線程不夠用時(shí)由調(diào)用的線程處理該任務(wù)
        taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        return taskExecutor;
    }
}

線程池參數(shù)

核心線程數(shù)量：CorePoolSize
看業(yè)務(wù)場(chǎng)景設(shè)置（我通常設(shè)置為CPU核心*1）

最大線程數(shù)量：MaxPoolSize
當(dāng)核心線程數(shù)量都在使用狀態(tài)時(shí)，會(huì)調(diào)用最大線程數(shù)量里的線程，使用的總線程不會(huì)超過(guò)最大線程數(shù)量，其余則等待（我通常設(shè)置為CPU核心*2）

隊(duì)列程度：QueueCapacity
線程隊(duì)列的大小

線程空閑時(shí)間：KeepAliveSeconds

線程前綴名稱：ThreadNamePrefix

停機(jī)策略：WaitForTasksToCompleteOnShutdown
該方法用來(lái)設(shè)置線程池關(guān)閉的時(shí)候等待所有任務(wù)都完成后，再繼續(xù) 銷毀其他的 Bean，這樣這些異步任務(wù) 的銷毀就會(huì)先于數(shù)據(jù)庫(kù)連接池對(duì)象的銷毀。

任務(wù)的等待時(shí)間：AwaitTerminationSeconds
任務(wù)的等待時(shí)間如果超過(guò)這個(gè)時(shí)間還沒(méi)有銷毀就強(qiáng)制銷毀，以確保應(yīng)用最后能夠被關(guān)閉，而不是阻塞住

拒接策略：RejectedExecutionHandler
線程不夠用時(shí)由調(diào)用的線程處理該任務(wù)