Java基礎——簡單實現線程池
先上原理圖:為了更好的在手機上顯示,我重新把圖畫了一遍
上代碼之前,要先補充一下線程池構造的核心幾個點
1. 線程池裡的核心線程數與最大線程數
2. 線程池裡真正工作的線程 worker
3. 線程池裡用來存取任務的隊列 BlockingQueue
4. 線程中的任務 task
本例實現簡化了一些,只實現了BlockingQueue存放任務,然後每個worker取任務並執行,下面看代碼
首先定義一個線程池ThreadExcutor
然後定義一個內部類Worker,這個內部類Worker是用來執行每個任務的,在創建線程池後,往線程里添加任務,每個任務都是由Worker一個一個來啟動的。
首先注意的一點,這個Worker是個內部類,是在線程池內聲明的。
exec方法
Worker怎麼工作
這個工作線程實例化的時候就先加入一個任務到隊列中,也就是說在實例化這個工作線程時,這個工作線程也是一個任務被加入到線程池中。然後就是run方法,這個run方法是線程調start方法生成的線程,而Worker調的run方法並沒有生成新的線程。就是一個循環,一直在不停的從隊列中取任務,然後執行。可以看到,取隊列的方法是take(),這個方法意思如果隊列為空了,取不到數據時就阻塞隊列。
然後看shutdown()
你每天辛勤的勞動著,突然接收到上面的命令,說活暫時不要接了,先停下來,當你還沒搞清楚狀況時,接著你的領導又把你開除了,說公司要倒了,你先下崗吧,一會我也得下崗了。這就是shutdown做的事,shutdown必須是主線程才能停止工作線程。
shutdown方法並不是用線程那種強制停止的搞法,而是先用一個標識符告訴工作線程,不要再接任務了。然後通知工作線程,你可以 interrupt() 了,當所有的線程停止後記得要把主線程也停掉,這樣,一個簡單任務的線程池就完成了。
讓我們來測試一下:
輸出結果為:
這當然是最簡單實現,JDK的實現比這強大的多,而且還具備當工作線程處理不過來時,可以產生新的線程來處理任務,這個數量不能超過原先定義的最大線程數,而在本例中都沒實現這些功能。
我相信當想了解一個模塊的功能時,如果一開始就了解其中最核心的點,然後向外慢慢擴展,那麼學習這個模塊時一定能省下不少時間,而且理解將很深刻。希望這個簡單線程池實現能讓你有所領悟,以更加簡單的方式了解線程池,了解了線程池,對於其他池化技術,原理都是相通的。
最後我想說:我相信寫好一篇文章能讓大家理解起來不困難都是用了心的,您也點個贊支持支持。
學習Java的同學注意了!!!
學習過程中遇到什麼問題或者想獲取學習資源的話,歡迎加入Java學習交流群495273252,我們一起學Java!


※自學的程序員如何找到好工作?
※快速認識Java內存區域劃分
※Java線程間通信之wait/notify
※Java集合——ArrayList
TAG:Java團長 |
※基於Netty的Android系統IM簡單實現原理
※深度學習對話系統實戰篇-簡單 chatbot 代碼實現
※Nodejs建站教程:註冊登錄流程的簡單實現
※基於htmlparser實現網頁內容解析
※用Python 實現的基礎機器學習演算法
※教程 | 從頭開始了解PyTorch的簡單實現
※用Numpy 實現簡單的 GAN
※Andrew Ng經典機器學習課程的Python實現2
※單線程實現同時監聽多個埠(windows平台c++代碼)
※Apache+Tomcat實現單機多網站部署
※HashMap實現原理
※教程|如何使用純NumPy代碼從頭實現簡單的卷積神經網路
※「谷歌量子霸權藍圖年內實現」演示量子計算機hello world程序
※任務調度並行演算法的Python簡單實現
※配置Apache伺服器實現瀏覽器訪問python程序
※OpenVPN|實現遠程桌面控制
※使用Python實現一個簡易Http伺服器
※谷歌量子霸權藍圖年內實現:演示量子計算機hello world程序
※「並發編程」Future模式及JDK中的實現
※Socket.io+canvas實現實時繪畫