一、配置

1.1 將 ThreadPoolTaskExecutor 注入到 spring 容器內

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

1.2 拒絕策略配置

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

• AbortPolicy：用于被拒絕任務的處理程序，它將拋出 RejectedExecutionException。
• CallerRunsPolicy：用于被拒絕任務的處理程序，它直接在 execute 方法的調用線程中運行被拒絕的任務。
• DiscardOldestPolicy：用于被拒絕任務的處理程序，它放棄最舊的未處理請求，然后重試 execute。
• DiscardPolicy：用于被拒絕任務的處理程序，默認情況下它將丟棄被拒絕的任務。

其他說明：

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

1.3 配置線程池個數(shù)

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

二、處理流程

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

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

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

三、關閉線程池

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

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

常用狀態(tài)：

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

通過繼承線程池，重寫beforeExecute，afterExecute 和 terminated 方法來在線程執(zhí)行任務前，線程執(zhí)行任務結束，和線程終結前獲取線程的運行情況，根據(jù)具體情況調整線程池的線程數(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í)行線程，方式一
        threadPoolTaskExecutor.execute(new Runnable() {
            @Override
            public void run() {
                for (int i = 0; i < 100; i++) {
                    System.out.println("new Runnable()"+i+"當前線程"+Thread.currentThread().getName());
                }
            }
        });
        // // 創(chuàng)建并執(zhí)行線程，方式二
        System.out.println("lambda");
        threadPoolTaskExecutor.execute(() -> {
            for (int i = 0; i < 100; i++) {
                System.out.println("lambda"+i+"當前線程"+Thread.currentThread().getName());
            }
        });
    }
}

運行截圖：

用lambda表達式實現(xiàn)Runnable

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

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

// 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();

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

最新評論