溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
本篇內容介紹了“Java多線程怎么自定義”的有關知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領大家學習一下如何處理這些情況吧！希望大家仔細閱讀，能夠學有所成！
自定義線程如何做？
public ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler) {
}
corePoolSize:核心線程數
maximumPoolSize:最大線程數
keepAliveTime + unit:線程回收時間
workQueue:任務較多時暫存到隊列
threadFactory:執行程序創建新線程時使用的工廠
handler:超出線程池容量以及隊列長度后拒絕任務的策略
線程池的工作原理：
提交任務，線程池中的線程數可以增長至corePoolSize，之后繼續提交任務將暫存至隊列中，如果隊列滿，則看是否能繼續增長線程數至maximumPoolSize，超出后將進行拒絕策略處理。顯然，如果采用無界隊列，那么maximumPoolSize將失效，線程池中的線程最多就是corePoolSize個線程工作。
keepAliveTime + unit
這里涉及到線程池回收線程。簡單來說，就是采用有界隊列，導致corePoolSize滿，隊列滿，不得已線程池的線程增長至maximumPoolSize，那么任務處理完畢后，線程池中多出corePoolSize的部分理應回收，那么等待多長時間，多長時間沒有任務后在進行回收的問題就是由上面的參數決定。
固定線程池 特點： 無界隊列，導致keepAliveTime/unit/maximumPoolSize失效，不存在拒絕； 隨著任務的增長，線程數將固定在corePoolSize。 |
單線程池 特點： 無界隊列+核心、最大線程數都是1。 打個簡單比喻，任務來了，不管多少，那么有序的放著，工人只有一個，那就按照順序處理任務就是了。就是一個單線程順序處理任務的情況。 |
緩存線程池 特點： 一個比較特殊的隊列：SynchronousQueue，沒有容量可言，提交任務就意味著一直阻塞等待任務的線程立刻得到任務進行執行。說白了，就是不要暫存到隊列中，任務直接提交給線程進行執行。由于任務無法暫存，因此緩存線程池會根據任務的實際情況，進行線程池的增長，直至maximumPoolSize(Integer.MAX_VALUE)。 注意到keepAliveTime被設置成了60S，意思就是說如果任務來了很多，緩存線程池創建了不少線程來對付它們，任務處理的差不多了，那么等待60S后，還沒有任務需要處理，那么進行線程回收處理。 |
定時線程池 特點： 利用延時隊列DelayedQueue(無界隊列)，完成線程池實現定時以及周期性執行任務的需要 |
拒絕策略
當線程池的任務緩存隊列已滿并且線程池中的線程數目達到maximumPoolSize，如果還有任務到來就會采取任務拒絕策略，通常有以下四種策略：
ThreadPoolExecutor.AbortPolicy:丟棄任務并拋出
RejectedExecutionException異常。
ThreadPoolExecutor.DiscardPolicy：也是丟棄任務，但是不拋出異常。
ThreadPoolExecutor.DiscardOldestPolicy：丟棄隊列最前面的任務，然后
重新嘗試執行任務（重復此過程）
ThreadPoolExecutor.CallerRunsPolicy：調用其他線程處理該任務
“Java多線程怎么自定義”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業相關的知識可以關注億速云網站，小編將為大家輸出更多高質量的實用文章！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
