ThreadPoolTaskExecutor介紹


ThreadPoolTaskExecutor是一個spring的線程池技術,其實,它的實現方式完全是使用ThreadPoolExecutor進行實現。對於ThreadPoolExecutor,有一些重要的參數如下:

(1)int corePoolSize:線程池維護線程的最小數量. 
(2)int maximumPoolSize:線程池維護線程的最大數量. 
(3)long keepAliveTime:空閑線程的存活時間. 
(4)TimeUnit unit: 時間單位,現有納秒,微秒,毫秒,秒枚舉值. 
(5)BlockingQueue<Runnable> workQueue:持有等待執行的任務隊列.

(6)RejectedExecutionHandler handler: 用來拒絕一個任務的執行。

 

ThreadPoolExecutor池子的處理流程如下:  

1)當池子大小小於corePoolSize就新建線程,並處理請求

2)當池子大小等於corePoolSize,把請求放入workQueue中,池子里的空閑線程就去從workQueue中取任務並處理

3)當workQueue放不下新入的任務時,新建線程入池,並處理請求,如果池子大小撐到了maximumPoolSize就用RejectedExecutionHandler來做拒絕處理

4)另外,當池子的線程數大於corePoolSize的時候,多余的線程會等待keepAliveTime長的時間,如果無請求可處理就自行銷毀

其會優先創建  corePoolSize 線程, 當繼續增加線程時,先放入Queue中,當 corePoolSize  和 Queue 都滿的時候,就增加創建新線程,當線程達到MaxPoolSize的時候,就會拋出錯 誤 org.springframework.core.task.TaskRejectedException

 

ThreadPoolTaskExecutor是直接使用ThreadPoolExecutor進行處理,運算規則一樣,在spring中使用ThreadPoolTaskExecutor的配置:

復制代碼
<bean id="threadPool"
        class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
        <!-- 核心線程數 -->
        <property name="corePoolSize" value="3" />
        <!-- 最大線程數 -->
        <property name="maxPoolSize" value="10" />
        <!-- 隊列最大長度 >=mainExecutor.maxSize -->
        <property name="queueCapacity" value="25" />
        <!-- 線程池維護線程所允許的空閑時間 -->
        <property name="keepAliveSeconds" value="300" />
        <!-- 線程池對拒絕任務(無線程可用)的處理策略 ThreadPoolExecutor.CallerRunsPolicy策略 ,調用者的線程會執行該任務,如果執行器已關閉,則丟棄.  -->
        <property name="rejectedExecutionHandler">
            <bean class="java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy" /> </property> </bean>
復制代碼

Reject策略預定義有四種: 
(1)ThreadPoolExecutor.AbortPolicy策略,是默認的策略,處理程序遭到拒絕將拋出運行時 RejectedExecutionException。 
(2)ThreadPoolExecutor.CallerRunsPolicy策略 ,調用者的線程會執行該任務,如果執行器已關閉,則丟棄. 
(3)ThreadPoolExecutor.DiscardPolicy策略,不能執行的任務將被丟棄. 
(4)ThreadPoolExecutor.DiscardOldestPolicy策略,如果執行程序尚未關閉,則位於工作隊列頭部的任務將被刪除,然后重試執行程序(如果再次失敗,則重復此過程).


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM