1、線程池簡介：
??? 多線程技術(shù)主要解決處理器單元內(nèi)多個(gè)線程執(zhí)行的問題，它可以顯著減少處理器單元的閑置時(shí)間，增加處理器單元的吞吐能力。????
??? 假設(shè)一個(gè)服務(wù)器完成一項(xiàng)任務(wù)所需時(shí)間為：T1 創(chuàng)建線程時(shí)間，T2 在線程中執(zhí)行任務(wù)的時(shí)間，T3 銷毀線程時(shí)間。

??? 如果：T1 + T3 遠(yuǎn)大于 T2，則可以采用線程池，以提高服務(wù)器性能。
??????????????? 一個(gè)線程池包括以下四個(gè)基本組成部分：
??????????????? 1、線程池管理器（ThreadPool）：用于創(chuàng)建并管理線程池，包括 創(chuàng)建線程池，銷毀線程池，添加新任務(wù)；
??????????????? 2、工作線程（PoolWorker）：線程池中線程，在沒有任務(wù)時(shí)處于等待狀態(tài)，可以循環(huán)的執(zhí)行任務(wù)；
??????????????? 3、任務(wù)接口（Task）：每個(gè)任務(wù)必須實(shí)現(xiàn)的接口，以供工作線程調(diào)度任務(wù)的執(zhí)行，它主要規(guī)定了任務(wù)的入口，任務(wù)執(zhí)行完后的收尾工作，任務(wù)的執(zhí)行狀態(tài)等；
??????????????? 4、任務(wù)隊(duì)列（taskQueue）：用于存放沒有處理的任務(wù)。提供一種緩沖機(jī)制。
????????????????
??? 線程池技術(shù)正是關(guān)注如何縮短或調(diào)整T1,T3時(shí)間的技術(shù)，從而提高服務(wù)器程序性能的。它把T1，T3分別安排在服務(wù)器程序的啟動(dòng)和結(jié)束的時(shí)間段或者一些空閑的時(shí)間段，這樣在服務(wù)器程序處理客戶請(qǐng)求時(shí)，不會(huì)有T1，T3的開銷了。
??? 線程池不僅調(diào)整T1,T3產(chǎn)生的時(shí)間段，而且它還顯著減少了創(chuàng)建線程的數(shù)目，看一個(gè)例子：
??? 假設(shè)一個(gè)服務(wù)器一天要處理50000個(gè)請(qǐng)求，并且每個(gè)請(qǐng)求需要一個(gè)單獨(dú)的線程完成。在線程池中，線程數(shù)一般是固定的，所以產(chǎn)生線程總數(shù)不會(huì)超過線程池中線程的數(shù)目，而如果服務(wù)器不利用線程池來處理這些請(qǐng)求則線程總數(shù)為50000。一般線程池大小是遠(yuǎn)小于50000。所以利用線程池的服務(wù)器程序不會(huì)為了創(chuàng)建50000而在處理請(qǐng)求時(shí)浪費(fèi)時(shí)間，從而提高效率。

??? 代碼實(shí)現(xiàn)中并沒有實(shí)現(xiàn)任務(wù)接口，而是把Runnable對(duì)象加入到線程池管理器（ThreadPool），然后剩下的事情就由線程池管理器（ThreadPool）來完成了

?

[java]?view plaincopy

package?mine.util.thread;??

??

import?java.util.LinkedList;??

import?java.util.List;??

??

/**?

?*?線程池類，線程管理器：創(chuàng)建線程，執(zhí)行任務(wù)，銷毀線程，獲取線程基本信息?

?*/??

public?final?class?ThreadPool?{??

????//?線程池中默認(rèn)線程的個(gè)數(shù)為5??

????private?static?int?worker_num?=?5;??

????//?工作線程??

????private?WorkThread[]?workThrads;??

????//?未處理的任務(wù)??

????private?static?volatile?int?finished_task?=?0;??

????//?任務(wù)隊(duì)列，作為一個(gè)緩沖,List線程不安全??

????private?List<Runnable>?taskQueue?=?new?LinkedList<Runnable>();??

????private?static?ThreadPool?threadPool;??

??

????//?創(chuàng)建具有默認(rèn)線程個(gè)數(shù)的線程池??

????private?ThreadPool()?{??

????????this(5);??

????}??

??

????//?創(chuàng)建線程池,worker_num為線程池中工作線程的個(gè)數(shù)??

????private?ThreadPool(int?worker_num)?{??

????????ThreadPool.worker_num?=?worker_num;??

????????workThrads?=?new?WorkThread[worker_num];??

????????for?(int?i?=?0;?i?<?worker_num;?i++)?{??

????????????workThrads[i]?=?new?WorkThread();??

????????????workThrads[i].start();//?開啟線程池中的線程??

????????}??

????}??

??

????//?單態(tài)模式，獲得一個(gè)默認(rèn)線程個(gè)數(shù)的線程池??

????public?static?ThreadPool?getThreadPool()?{??

????????return?getThreadPool(ThreadPool.worker_num);??

????}??

??

????//?單態(tài)模式，獲得一個(gè)指定線程個(gè)數(shù)的線程池,worker_num(>0)為線程池中工作線程的個(gè)數(shù)??

????//?worker_num<=0創(chuàng)建默認(rèn)的工作線程個(gè)數(shù)??

????public?static?ThreadPool?getThreadPool(int?worker_num1)?{??

????????if?(worker_num1?<=?0)??

????????????worker_num1?=?ThreadPool.worker_num;??

????????if?(threadPool?==?null)??

????????????threadPool?=?new?ThreadPool(worker_num1);??

????????return?threadPool;??

????}??

??

????//?執(zhí)行任務(wù),其實(shí)只是把任務(wù)加入任務(wù)隊(duì)列，什么時(shí)候執(zhí)行有線程池管理器覺定??

????public?void?execute(Runnable?task)?{??

????????synchronized?(taskQueue)?{??

????????????taskQueue.add(task);??

????????????taskQueue.notify();??

????????}??

????}??

??

????//?批量執(zhí)行任務(wù),其實(shí)只是把任務(wù)加入任務(wù)隊(duì)列，什么時(shí)候執(zhí)行有線程池管理器覺定??

????public?void?execute(Runnable[]?task)?{??

????????synchronized?(taskQueue)?{??

????????????for?(Runnable?t?:?task)??

????????????????taskQueue.add(t);??

????????????taskQueue.notify();??

????????}??

????}??

??

????//?批量執(zhí)行任務(wù),其實(shí)只是把任務(wù)加入任務(wù)隊(duì)列，什么時(shí)候執(zhí)行有線程池管理器覺定??

????public?void?execute(List<Runnable>?task)?{??

????????synchronized?(taskQueue)?{??

????????????for?(Runnable?t?:?task)??

????????????????taskQueue.add(t);??

????????????taskQueue.notify();??

????????}??

????}??

??

????//?銷毀線程池,該方法保證在所有任務(wù)都完成的情況下才銷毀所有線程，否則等待任務(wù)完成才銷毀??

????public?void?destroy()?{??

????????while?(!taskQueue.isEmpty())?{//?如果還有任務(wù)沒執(zhí)行完成，就先睡會(huì)吧??

????????????try?{??

????????????????Thread.sleep(10);??

????????????}?catch?(InterruptedException?e)?{??

????????????????e.printStackTrace();??

????????????}??

????????}??

????????//?工作線程停止工作，且置為null??

????????for?(int?i?=?0;?i?<?worker_num;?i++)?{??

????????????workThrads[i].stopWorker();??

????????????workThrads[i]?=?null;??

????????}??

????????threadPool=null;??

????????taskQueue.clear();//?清空任務(wù)隊(duì)列??

????}??

??

????//?返回工作線程的個(gè)數(shù)??

????public?int?getWorkThreadNumber()?{??

????????return?worker_num;??

????}??

??

????//?返回已完成任務(wù)的個(gè)數(shù),這里的已完成是只出了任務(wù)隊(duì)列的任務(wù)個(gè)數(shù)，可能該任務(wù)并沒有實(shí)際執(zhí)行完成??

????public?int?getFinishedTasknumber()?{??

????????return?finished_task;??

????}??

??

????//?返回任務(wù)隊(duì)列的長度，即還沒處理的任務(wù)個(gè)數(shù)??

????public?int?getWaitTasknumber()?{??

????????return?taskQueue.size();??

????}??

??

????//?覆蓋toString方法，返回線程池信息：工作線程個(gè)數(shù)和已完成任務(wù)個(gè)數(shù)??

????@Override??

????public?String?toString()?{??

????????return?"WorkThread?number:"?+?worker_num?+?"??finished?task?number:"??

????????????????+?finished_task?+?"??wait?task?number:"?+?getWaitTasknumber();??

????}??

??

????/**?

?????*?內(nèi)部類，工作線程?

?????*/??

????private?class?WorkThread?extends?Thread?{??

????????//?該工作線程是否有效，用于結(jié)束該工作線程??

????????private?boolean?isRunning?=?true;??

??

????????/*?

?????????*?關(guān)鍵所在啊，如果任務(wù)隊(duì)列不空，則取出任務(wù)執(zhí)行，若任務(wù)隊(duì)列空，則等待?

?????????*/??

????????@Override??

????????public?void?run()?{??

????????????Runnable?r?=?null;??

????????????while?(isRunning)?{//?注意，若線程無效則自然結(jié)束run方法，該線程就沒用了??

????????????????synchronized?(taskQueue)?{??

????????????????????while?(isRunning?&&?taskQueue.isEmpty())?{//?隊(duì)列為空??

????????????????????????try?{??

????????????????????????????taskQueue.wait(20);??

????????????????????????}?catch?(InterruptedException?e)?{??

????????????????????????????e.printStackTrace();??

????????????????????????}??

????????????????????}??

????????????????????if?(!taskQueue.isEmpty())??

????????????????????????r?=?taskQueue.remove(0);//?取出任務(wù)??

????????????????}??

????????????????if?(r?!=?null)?{??

????????????????????r.run();//?執(zhí)行任務(wù)??

????????????????}??

????????????????finished_task++;??

????????????????r?=?null;??

????????????}??

????????}??

??

????????//?停止工作，讓該線程自然執(zhí)行完run方法，自然結(jié)束??

????????public?void?stopWorker()?{??

????????????isRunning?=?false;??

????????}??

????}??

}??

?

測試代碼：

[java]?view plaincopy

package?mine.util.thread;??

??

//測試線程池??

public?class?TestThreadPool?{??

????public?static?void?main(String[]?args)?{??

????????//?創(chuàng)建3個(gè)線程的線程池??

????????ThreadPool?t?=?ThreadPool.getThreadPool(3);??

????????t.execute(new?Runnable[]?{?new?Task(),?new?Task(),?new?Task()?});??

????????t.execute(new?Runnable[]?{?new?Task(),?new?Task(),?new?Task()?});??

????????System.out.println(t);??

????????t.destroy();//?所有線程都執(zhí)行完成才destory??

????????System.out.println(t);??

????}??

??

????//?任務(wù)類??

????static?class?Task?implements?Runnable?{??

????????private?static?volatile?int?i?=?1;??

??

????????@Override??

????????public?void?run()?{//?執(zhí)行任務(wù)??

????????????System.out.println("任務(wù)?"?+?(i++)?+?"?完成");??

????????}??

????}??

}??

?

運(yùn)行結(jié)果：

WorkThread number:3? finished task number:0? wait task number:6
任務(wù) 1 完成
任務(wù) 2 完成
任務(wù) 3 完成
任務(wù) 4 完成
任務(wù) 5 完成
任務(wù) 6 完成
WorkThread number:3? finished task number:6? wait task number:0

分析：由于并沒有任務(wù)接口，傳入的可以是自定義的任何任務(wù)，所以線程池并不能準(zhǔn)確的判斷該任務(wù)是否真正的已經(jīng)完成（真正完成該任務(wù)是這個(gè)任務(wù)的run方法執(zhí)行完畢），只能知道該任務(wù)已經(jīng)出了任務(wù)隊(duì)列，正在執(zhí)行或者已經(jīng)完成。

?

2、java類庫中提供的線程池簡介：

???? java提供的線程池更加強(qiáng)大，相信理解線程池的工作原理，看類庫中的線程池就不會(huì)感到陌生了。

?

?

?

?

?

其他具體內(nèi)容查看jdk幫助或看jdk源代碼吧。。。

參考文章：http://hi.baidu.com/obullxl/blog/item/ee50ad1ba8e8ff1f8718bf66.html

轉(zhuǎn)載于:https://www.cnblogs.com/kinghitomi/archive/2012/01/19/2327418.html

總結(jié)

以上是生活随笔為你收集整理的java多线程总结五：线程池的原理及实现的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。