大師，最近我在學(xué)習(xí)線程，有很多迷惑的地方。

說來聽聽，讓為師給你排解一下。

第一個(gè)問題問題就是為什么要多線程啊， 我看了操作系統(tǒng)中的多進(jìn)程管理，不是挺好的嗎？ 多線程似乎沒有必要啊！

不錯(cuò)，多問問為什么，總是有好處的。所謂線程，就是程序代碼的執(zhí)行，一個(gè)進(jìn)程至少得有一個(gè)線程，要不然，這個(gè)進(jìn)程怎么運(yùn)行？ 對(duì)吧？

這個(gè)我理解。

以你常用的Word為例，假設(shè)這個(gè)進(jìn)程沒有多線程（或者說它只有一個(gè)線程）， 如果它有個(gè)定時(shí)保存文檔的功能，你想象下，當(dāng)這個(gè)自動(dòng)保存的功能在運(yùn)行的時(shí)候，你還能繼續(xù)輸入文字嗎？

不能

對(duì)，這就是問題所在了，單線程只能干一件事情，無法并發(fā)和并行。直接導(dǎo)致用戶體驗(yàn)不好。CPU快速的運(yùn)算能力，還有多核，就被浪費(fèi)了。

那我完全可以用多進(jìn)程來處理啊， 一個(gè)進(jìn)程來接受用戶輸入文字，另外一個(gè)進(jìn)程來自動(dòng)保存。

是可以這么做，但進(jìn)程是個(gè)重量級(jí)的家伙，并且進(jìn)程之間是隔離的，他們要想共享數(shù)據(jù)，例如被編輯的文件內(nèi)容，那是非常麻煩的。

原來如此。

古人云：進(jìn)程是擁有資源的基本單位， 線程是CPU調(diào)度的基本單位，這句話你理解嗎？

不是特別明白......

舉個(gè)例子，有兩個(gè)進(jìn)程，一個(gè)是Word， 一個(gè)是QQ音樂。 Word 進(jìn)程打開了文件，這是它的資源，QQ音樂打開了Socket，這也是它的資源。

假設(shè)Word有兩個(gè)線程：T1負(fù)責(zé)接受用戶的文字輸入，T2 負(fù)責(zé)自動(dòng)保存。

QQ音樂也有兩個(gè)線程：T3負(fù)責(zé)從Socket中讀取數(shù)據(jù)，T4負(fù)責(zé)對(duì)音樂數(shù)據(jù)進(jìn)行解碼。

操作系統(tǒng)在做調(diào)度的時(shí)候，基本單位不是Word,QQ音樂這樣的進(jìn)程，而是T1, T2,T3,T4這些線程。明白了嗎？

（點(diǎn)頭）原來每個(gè)線程執(zhí)行的都是進(jìn)程代碼的某個(gè)片段啊！ 對(duì)了，我聽?zhēng)熜謧冊(cè)谟懻撌裁?a href="http://m.xsypw.cn/v/tag/852/" target="_blank">Java多線程編程，說是很復(fù)雜，但是他們從來沒提到過Java 多進(jìn)程編程，這是怎么回事啊？

不錯(cuò)，你的師兄們都沒有想到這個(gè)問題，看來你已經(jīng)開始思考了。我先問你，你寫的Java程序是不是運(yùn)行在JVM中？ 對(duì)操作系統(tǒng)來說，JVM是個(gè)什么東西？

嗯... JVM其實(shí)就是java.exe運(yùn)行起來，那它肯定是個(gè)進(jìn)程了。

那在一個(gè)進(jìn)程中還能進(jìn)行多進(jìn)程編程嗎？

（恍然大悟）奧，那是肯定不行了，Java程序運(yùn)行在JVM當(dāng)中， JVM這個(gè)進(jìn)程其實(shí)就是他們的容器。 我聽說Python, Ruby 等動(dòng)態(tài)語言也都有虛擬機(jī)， 這么說他們也可以進(jìn)行多線程編程了。

是啊，虛擬機(jī)是個(gè)好東西，你們真是遇上了好時(shí)候啊， 不用再費(fèi)勁心機(jī)去操作內(nèi)存。這虛擬機(jī)還能屏蔽操作系統(tǒng)的差異，你寫的程序可以在任意的支持該語言虛擬機(jī)的操作系統(tǒng)中運(yùn)行。 可移植性很重要，要不然，你在Mac/Windows上開發(fā)的程序怎么能不加修改地放到Linux上去運(yùn)行呢？

我在Java 中創(chuàng)建了一個(gè)Thread對(duì)象，為什么要調(diào)用start方法才能啟動(dòng)線程？ 為什么不能直接調(diào)用run方法呢？

你要是直接調(diào)用run()方法，會(huì)是什么效果？

就是用當(dāng)前線程去執(zhí)行一個(gè)普通函數(shù)而已，根本沒有什么新線程創(chuàng)建出來。

這就對(duì)了，你想創(chuàng)建一個(gè)新的線程出來，肯定得有準(zhǔn)備工作啊，設(shè)置好這個(gè)線程的上下文，比如這個(gè)線程的棧（用于函數(shù)調(diào)用），線程的狀態(tài)，這個(gè)線程的PC(Program Counter）等等一系列信息以后，這個(gè)線程才可以被調(diào)度， 一旦被調(diào)度，就會(huì)執(zhí)行那個(gè)run()方法了

明白了大師，還有一個(gè)問題，既然線程是屬于進(jìn)程的，可以共享進(jìn)程的資源， 那創(chuàng)建一個(gè)線程應(yīng)該很輕松啊，為什么要有線程池這個(gè)東西呢？

雖然線程是個(gè)輕量級(jí)的東西， 但是對(duì)于互聯(lián)網(wǎng)應(yīng)用來說，如果每個(gè)用戶的請(qǐng)求都創(chuàng)建一個(gè)線程，那會(huì)非常得多，服務(wù)器也是難于承受， 再說了，眾多的線程去競(jìng)爭(zhēng)CPU，不斷切換，也會(huì)讓CPU調(diào)度不堪重負(fù)，很多線程將不得不等待。所以前輩們的思路就是（1）用少量的線程 （2） 讓線程保持忙碌

奧，就是說只創(chuàng)建一定數(shù)量的線程，讓這些線程去處理所有的任務(wù)，任務(wù)執(zhí)行完了以后，線程并不結(jié)束，而是回到線程池中去，等待接受下一個(gè)任務(wù)。

這些線程可以預(yù)先創(chuàng)建，任務(wù)來了就不用臨時(shí)再創(chuàng)建了，立刻開始服務(wù)。

預(yù)先創(chuàng)建？ 您剛才不是說線程是程序代碼的執(zhí)行嗎？ 它是個(gè)動(dòng)態(tài)的東西，怎么可能預(yù)先創(chuàng)建？ 如果真的創(chuàng)建起來了，就會(huì)調(diào)用run方法， 馬上執(zhí)行完了， 線程就結(jié)束了！

你忘了重要的一點(diǎn)，線程的狀態(tài)。當(dāng)線程池的線程剛創(chuàng)建時(shí)，讓他們進(jìn)入阻塞狀態(tài)：等待某個(gè)任務(wù)的到來。 如果任務(wù)來了，那就好辦，喚醒其中一個(gè)線程，讓它拿到任務(wù)去執(zhí)行即可。

可是怎么讓他們進(jìn)入阻塞狀態(tài)？

看來之前的圖我白畫了， BlockingQueue聽說過沒有？ 沒聽說過？ 其實(shí)很簡(jiǎn)單，就是一個(gè)線程調(diào)用它的take()方法取數(shù)據(jù)時(shí)， 如果這個(gè)Queue中沒有數(shù)據(jù)，該線程會(huì)阻塞；同樣，一個(gè)線程調(diào)用它的put方法放數(shù)據(jù)時(shí)，如果Queue滿了， 也會(huì)阻塞。

奧，看來線程池中每個(gè)線程的run（）方法中，要設(shè)置一個(gè)循環(huán)，每次都嘗試從BlockingQueue中獲取任務(wù)，如果Queue是空的，就阻塞等待， 如果有任務(wù)來了，就會(huì)通知到線程池的某一個(gè)線程去處理，處理完了以后，依然試圖從BlockingQueue中獲取任務(wù)，就這么依次循環(huán)下去。

線程池中的Worker線程：public class WorkerThread extends Thread { private BlockingQueue taskQueue = null; private boolean isStopped = false; //持有一個(gè)BlockingQueue的實(shí)例 public WorkerThread(BlockingQueue queue){ taskQueue = queue; } public void run(){ while(!isStopped()){ try{ Task task = taskQueue.take(); task.execute(); } catch(Exception e){ //log or otherwise report exception, //but keep pool thread alive. } } } ......略......}

沒錯(cuò)，你這個(gè)代碼是一種簡(jiǎn)單的實(shí)現(xiàn)，我的老朋友Doug Lea大師寫了一套非常好的實(shí)現(xiàn)，已經(jīng)被吸收進(jìn)JDK了，作為java.util.concurrent包的一部分，你直接調(diào)用即可，不用自己動(dòng)手了。

ExecutorService executorService = Executors.newFixedThreadPool(10);executorService.execute(new Runnable() { public void run() { System.out.println("Asynchronous task"); }});executorService.shutdown();