更新時間:2020-02-27 11:06:34 來源:動力節(jié)點 瀏覽3334次
開發(fā)中經(jīng)常會遇到各種池(如:連接池,線程池),它們的作用就是為了提高性能及減少開銷,在JDK1.5以后的java.util.concurrent包中內(nèi)置了很多不同使用場景的線程池,為了更好的理解它們,自己手寫一個線程池,加深印象。
概述
1.什么是池
它的基本思想就是一種對象池,程序初始化的時候開辟一塊內(nèi)存空間,里面存放若干個線程對象,池中線程執(zhí)行調(diào)度由池管理器來處理。當(dāng)有線程任務(wù)時,從池中取一個,執(zhí)行完成后線程對象歸池,這樣可以避免反復(fù)創(chuàng)建線程對象所帶來的性能開銷,節(jié)省系統(tǒng)的資源。
2.使用線程池的好處
合理的使用線程池可以重復(fù)利用已創(chuàng)建的線程,這樣就可以減少在創(chuàng)建線程和銷毀線程上花費的時間和資源。并且,線程池在某些情況下還能動態(tài)調(diào)整工作線程的數(shù)量,以平衡資源消耗和工作效率。同時線程池還提供了對池中工作線程進(jìn)行統(tǒng)一的管理的相關(guān)方法。這樣就相當(dāng)于我們一次創(chuàng)建,就可以多次使用,大量的節(jié)省了系統(tǒng)頻繁的創(chuàng)建和銷毀線程所需要的資源。
包含功能:
1.創(chuàng)建線程池,銷毀線程池,添加新任務(wù)
2.沒有任務(wù)進(jìn)入等待,有任務(wù)則處理掉
3.動態(tài)伸縮,擴(kuò)容
4.拒絕策略
介紹了線程池的原理以及主要組件之后,就讓我們來手動實現(xiàn)一個自己的線程池,以加深理解和深入學(xué)習(xí)。因為自己實現(xiàn)的簡易版本所以不建議生產(chǎn)中使用,生產(chǎn)中使用java.util.concurrent會更加健壯和優(yōu)雅。
代碼
以下線程池相關(guān)代碼均在SimpleThreadPoolExecutor.java中,由于為了便于解讀因此以代碼塊的形式呈現(xiàn)
維護(hù)一個內(nèi)部枚舉類,用來標(biāo)記當(dāng)前任務(wù)線程狀態(tài),在Thread中其實也有.
任務(wù)線程具體實現(xiàn)
1.繼承Thread,重寫run方法。
2.this.taskState==TaskState.FREE&&TASK_QUEUE.isEmpty()如果當(dāng)前線程處于空閑狀態(tài)且沒有任何任務(wù)了就將它wait住,讓出CPU執(zhí)行權(quán)
3.如果有任務(wù)就去執(zhí)行FIFO(先進(jìn)先出)策略
4.定義close方法,關(guān)閉線程,當(dāng)然這里不能暴力關(guān)閉,所以這里有需要借助interrupt
簡易版線程池,主要就是維護(hù)了一個任務(wù)隊列和線程集,為了動態(tài)擴(kuò)容,自己也繼承了Thread去做監(jiān)聽操作,對外提供submit()提交執(zhí)行任務(wù)、shutdown()等待所有任務(wù)工作完畢,關(guān)閉線程池
測試一把
創(chuàng)建一個測試類
日志分析:從日志中可以看到,初始化的時候是2個線程在工作,執(zhí)行速度較為緩慢,當(dāng)經(jīng)過第一次擴(kuò)容后,會觀察到線程池里線程個數(shù)增加了,執(zhí)行任務(wù)的速度就越來越快了,本文一共擴(kuò)容了2次,第一次是擴(kuò)容到activeSize的大小,第二次是擴(kuò)容到maxSize,在執(zhí)行任務(wù)的過程中,當(dāng)線程數(shù)過多的時候就會觸發(fā)回收機(jī)制...
總結(jié)
通過本文,大致可以了解線程池的工作原理和實現(xiàn)方式,學(xué)習(xí)的過程中,就是要知其然知其所以然。這樣才能更好地駕馭它,更好地去理解和使用,也能更好地幫助我們觸類旁通,后面的文章中會詳細(xì)介紹java.util.concurrent中的線程池。
以上就是動力節(jié)點Java培訓(xùn)機(jī)構(gòu)小編介紹的“Java線程池學(xué)習(xí)教程:實現(xiàn)簡易線程池!”的內(nèi)容,希望對大家有幫助,如有疑問,請在線咨詢,有專業(yè)老師隨時為你服務(wù)。
相關(guān)閱讀