一、配置

1.1 將 ThreadPoolTaskExecutor 注入到 spring 容器內(nèi)

@Configuration
public class ThreadTaskPoolExecutorConfiguration {
    @Bean
    public ThreadPoolTaskExecutor threadPoolTaskExecutor(){
        ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
        // 核心線(xiàn)程數(shù)
        taskExecutor.setCorePoolSize(5);
        // 最大線(xiàn)程數(shù)
        taskExecutor.setMaxPoolSize(15);
        // 隊(duì)列大小 默認(rèn)使用LinkedBlockingQueue
        taskExecutor.setQueueCapacity(100);
        // 線(xiàn)程最大空閑時(shí)間
        taskExecutor.setKeepAliveSeconds(300);
        // 拒絕策略 默認(rèn)new ThreadPoolExecutor.AbortPolicy()
        taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        // 線(xiàn)程名稱(chēng)前綴
        taskExecutor.setThreadNamePrefix("My-Task-Executor-");
        //交給spring托管的會(huì)自動(dòng)初始化，因?yàn)閷?shí)現(xiàn)了InitializingBean接口
        // taskExecutor.initialize();
        return taskExecutor;
    }
}

1.2 拒絕策略配置

rejectedExecutionHandler 字段用于配置拒絕策略，常用的拒絕策略如下：

• AbortPolicy：用于被拒絕任務(wù)的處理程序，它將拋出 RejectedExecutionException。
• CallerRunsPolicy：用于被拒絕任務(wù)的處理程序，它直接在 execute 方法的調(diào)用線(xiàn)程中運(yùn)行被拒絕的任務(wù)。
• DiscardOldestPolicy：用于被拒絕任務(wù)的處理程序，它放棄最舊的未處理請(qǐng)求，然后重試 execute。
• DiscardPolicy：用于被拒絕任務(wù)的處理程序，默認(rèn)情況下它將丟棄被拒絕的任務(wù)。

其他說(shuō)明：

• 為了實(shí)現(xiàn)某些特殊的業(yè)務(wù)需求，用戶(hù)可以選擇使用自定義策略，只需實(shí)現(xiàn)RejectedExecutionHandler接口即可。
• 建議配置threadNamePrefix屬性，出問(wèn)題時(shí)可以更方便的進(jìn)行排查。

1.3 配置線(xiàn)程池個(gè)數(shù)

• 如果是 CPU 密集型任務(wù)，那么線(xiàn)程池的線(xiàn)程個(gè)數(shù)應(yīng)該盡量少一些，一般為 CPU 的個(gè)數(shù)+1條線(xiàn)程。
• 如果是 IO 密集型任務(wù)，那么線(xiàn)程池的線(xiàn)程可以放的很大，如 2*CPU 的個(gè)數(shù)。
• 對(duì)于混合型任務(wù)，如果可以拆分的話(huà)，通過(guò)拆分成 CPU 密集型和 IO 密集型兩種來(lái)提高執(zhí)行效率；如果不能拆分的的話(huà)就可以根據(jù)實(shí)際情況來(lái)調(diào)整線(xiàn)程池中線(xiàn)程的個(gè)數(shù)

二、處理流程

1. 當(dāng)一個(gè)任務(wù)被提交到線(xiàn)程池時(shí)，首先查看線(xiàn)程池的核心線(xiàn)程是否都在執(zhí)行任務(wù)，否就選擇一條線(xiàn)程執(zhí)行任務(wù)，是就執(zhí)行第二步。
2. 查看核心線(xiàn)程池是否已滿(mǎn)，不滿(mǎn)就創(chuàng)建一條線(xiàn)程執(zhí)行任務(wù)，否則執(zhí)行第三步。
3. 查看任務(wù)隊(duì)列是否已滿(mǎn)，不滿(mǎn)就將任務(wù)存儲(chǔ)在任務(wù)隊(duì)列中，否則執(zhí)行第四步。
4. 查看線(xiàn)程池是否已滿(mǎn)，不滿(mǎn)就創(chuàng)建一條線(xiàn)程執(zhí)行任務(wù)，否則就按照策略處理無(wú)法執(zhí)行的任務(wù)。

在 ThreadPoolExecutor 中表現(xiàn)為:

• 如果當(dāng)前運(yùn)行的線(xiàn)程數(shù)小于corePoolSize，那么就創(chuàng)建線(xiàn)程來(lái)執(zhí)行任務(wù)（執(zhí)行時(shí)需要獲取全局鎖）。
• 如果運(yùn)行的線(xiàn)程大于或等于corePoolSize，那么就把task加入BlockQueue。
• 如果創(chuàng)建的線(xiàn)程數(shù)量大于BlockQueue的最大容量，那么創(chuàng)建新線(xiàn)程來(lái)執(zhí)行該任務(wù)。
• 如果創(chuàng)建線(xiàn)程導(dǎo)致當(dāng)前運(yùn)行的線(xiàn)程數(shù)超過(guò)maximumPoolSize，就根據(jù)飽和策略來(lái)拒絕該任務(wù)。

三、關(guān)閉線(xiàn)程池

調(diào)用shutdown或者shutdownNow，兩者都不會(huì)接受新的任務(wù)，而且通過(guò)調(diào)用要停止線(xiàn)程的interrupt方法來(lái)中斷線(xiàn)程，有可能線(xiàn)程永遠(yuǎn)不會(huì)被中斷，不同之處在于shutdownNow會(huì)首先將線(xiàn)程池的狀態(tài)設(shè)置為STOP，然后嘗試停止所有線(xiàn)程（有可能導(dǎo)致部分任務(wù)沒(méi)有執(zhí)行完）然后返回未執(zhí)行任務(wù)的列表。而shutdown則只是將線(xiàn)程池的狀態(tài)設(shè)置為shutdown，然后中斷所有沒(méi)有執(zhí)行任務(wù)的線(xiàn)程，并將剩余的任務(wù)執(zhí)行完。

四、監(jiān)控線(xiàn)程池狀態(tài)

常用狀態(tài)：

• taskCount：線(xiàn)程需要執(zhí)行的任務(wù)個(gè)數(shù)。
• completedTaskCount：線(xiàn)程池在運(yùn)行過(guò)程中已完成的任務(wù)數(shù)。
• largestPoolSize：線(xiàn)程池曾經(jīng)創(chuàng)建過(guò)的最大線(xiàn)程數(shù)量。
• getPoolSize獲取當(dāng)前線(xiàn)程池的線(xiàn)程數(shù)量。
• getActiveCount：獲取活動(dòng)的線(xiàn)程的數(shù)量

通過(guò)繼承線(xiàn)程池，重寫(xiě)beforeExecute，afterExecute 和 terminated 方法來(lái)在線(xiàn)程執(zhí)行任務(wù)前，線(xiàn)程執(zhí)行任務(wù)結(jié)束，和線(xiàn)程終結(jié)前獲取線(xiàn)程的運(yùn)行情況，根據(jù)具體情況調(diào)整線(xiàn)程池的線(xiàn)程數(shù)量。

五、實(shí)戰(zhàn)

@RunWith(SpringRunner.class)
@SpringBootTest(classes = TestApplication.class)
public class TestApplicationTests {
    // 注入ThreadPoolTaskExecutor
    @Resource
    private ThreadPoolTaskExecutor threadPoolTaskExecutor;
    @Test
    public void ThreadTest(){
        System.out.println(threadPoolTaskExecutor);
        System.out.println("new Runnable()");
        // 創(chuàng)建并執(zhí)行線(xiàn)程，方式一
        threadPoolTaskExecutor.execute(new Runnable() {
            @Override
            public void run() {
                for (int i = 0; i < 100; i++) {
                    System.out.println("new Runnable()"+i+"當(dāng)前線(xiàn)程"+Thread.currentThread().getName());
                }
            }
        });
        // // 創(chuàng)建并執(zhí)行線(xiàn)程，方式二
        System.out.println("lambda");
        threadPoolTaskExecutor.execute(() -> {
            for (int i = 0; i < 100; i++) {
                System.out.println("lambda"+i+"當(dāng)前線(xiàn)程"+Thread.currentThread().getName());
            }
        });
    }
}

運(yùn)行截圖：

用lambda表達(dá)式實(shí)現(xiàn)Runnable

我開(kāi)始使用Java 8時(shí)，首先做的就是使用lambda表達(dá)式替換匿名類(lèi)，而實(shí)現(xiàn)Runnable接口是匿名類(lèi)的最好示例。

看一下Java 8之前的runnable實(shí)現(xiàn)方法，需要4行代碼，而使用lambda表達(dá)式只需要一行代碼。我們?cè)谶@里做了什么呢？那就是用() -> {}代碼塊替代了整個(gè)匿名類(lèi)。

// Java 8之前：
new Thread(new Runnable() {
 @Override
 public void run() {
 System.out.println("Before Java8, too much code for too little to do");
 }
}).start();
//Java 8方式：
new Thread( () -> System.out.println("In Java8, Lambda expression rocks !!") ).start();

到此這篇關(guān)于Spring中的ThreadPoolTaskExecutor線(xiàn)程池使用詳解的文章就介紹到這了,更多相關(guān)ThreadPoolTaskExecutor線(xiàn)程池內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論