生命周期

　　在 Java 領(lǐng)域，實(shí)現(xiàn)并發(fā)程序的主要手段就是多線(xiàn)程。線(xiàn)程是本身就是操作系統(tǒng)里的一個(gè)概念，不同的開(kāi)發(fā)語(yǔ)言如 Java、C# 等都對(duì)其進(jìn)行了封裝，但是萬(wàn)變不離操作系統(tǒng)。

　　Java 語(yǔ)言里的線(xiàn)程本質(zhì)上就是操作系統(tǒng)的線(xiàn)程，它們是一一對(duì)應(yīng)的。

　　在操作系統(tǒng)層面，線(xiàn)程也有“生老病死”，專(zhuān)業(yè)的說(shuō)法叫有生命周期。對(duì)于有生命周期的事物，要學(xué)好它，思路非常簡(jiǎn)單，只要能搞懂生命周期中各個(gè)節(jié)點(diǎn)的狀態(tài)轉(zhuǎn)換機(jī)制即可。

　　雖然不同的開(kāi)發(fā)語(yǔ)言對(duì)于操作系統(tǒng)線(xiàn)程進(jìn)行了不同的封裝，但是對(duì)于線(xiàn)程的生命周期這部分，基本上是雷同的。

　　通用的線(xiàn)程生命周期基本上可以用 初始狀態(tài)、可運(yùn)行狀態(tài)、運(yùn)行狀態(tài)、休眠狀態(tài)和終止?fàn)顟B(tài)等“五態(tài)模型”來(lái)描述。

　　Java 語(yǔ)言中線(xiàn)程共有六種狀態(tài)，分別是：NEW(初始化狀態(tài))RUNNABLE(可運(yùn)行 / 運(yùn)行狀態(tài))BLOCKED(阻塞狀態(tài))WAITING(無(wú)時(shí)限等待)TIMED_WAITING(有時(shí)限等待)TERMINATED(終止?fàn)顟B(tài))。

　　其實(shí)在操作系統(tǒng)層面，Java 線(xiàn)程中的 BLOCKED、WAITING、TIMED_WAITING 是一種狀態(tài)，即前面我們提到的休眠狀態(tài)。也就是說(shuō)只要 Java 線(xiàn)程處于這三種狀態(tài)之一，那么這個(gè)線(xiàn)程就永遠(yuǎn)沒(méi)有 CPU 的使用權(quán)。

　　其中，BLOCKED、WAITING、TIMED_WAITING 可以理解為線(xiàn)程導(dǎo)致休眠狀態(tài)的三種原因。那具體是哪些情形會(huì)導(dǎo)致線(xiàn)程從 RUNNABLE 狀態(tài)轉(zhuǎn)換到這三種狀態(tài)呢?而這三種狀態(tài)又是何時(shí)轉(zhuǎn)換回 RUNNABLE 的呢?以及 NEW、TERMINATED 和 RUNNABLE 狀態(tài)是如何轉(zhuǎn)換的?

　　1. RUNNABLE 與 BLOCKED 的狀態(tài)轉(zhuǎn)換

　　只有一種場(chǎng)景會(huì)觸發(fā)這種轉(zhuǎn)換，就是線(xiàn)程等待 synchronized 的隱式鎖。synchronized 修飾的方法、代碼塊同一時(shí)刻只允許一個(gè)線(xiàn)程執(zhí)行，其他線(xiàn)程只能等待，這種情況下，等待的線(xiàn)程就會(huì)從 RUNNABLE 轉(zhuǎn)換到 BLOCKED 狀態(tài)。而當(dāng)?shù)却木€(xiàn)程獲得 synchronized 隱式鎖時(shí)，就又會(huì)從 BLOCKED 轉(zhuǎn)換到 RUNNABLE 狀態(tài)。

　　2. RUNNABLE 與 WAITING 的狀態(tài)轉(zhuǎn)換

　　總體來(lái)說(shuō)，有三種場(chǎng)景會(huì)觸發(fā)這種轉(zhuǎn)換，其中：

　　第一種場(chǎng)景，獲得 synchronized 隱式鎖的線(xiàn)程，調(diào)用無(wú)參數(shù)的 Object.wait() 方法。其中，wait() 方法我們?cè)谏弦黄v解管程的時(shí)候已經(jīng)深入介紹過(guò)了，這里就不再贅述。

　　第二種場(chǎng)景，調(diào)用無(wú)參數(shù)的 Thread.join() 方法。其中的 join() 是一種線(xiàn)程同步方法，例如有一個(gè)線(xiàn)程對(duì)象 thread A，當(dāng)調(diào)用 A.join() 的時(shí)候，執(zhí)行這條語(yǔ)句的線(xiàn)程會(huì)等待 thread A 執(zhí)行完，而等待中的這個(gè)線(xiàn)程，其狀態(tài)會(huì)從 RUNNABLE 轉(zhuǎn)換到 WAITING。當(dāng)線(xiàn)程 thread A 執(zhí)行完，原來(lái)等待它的線(xiàn)程又會(huì)從 WAITING 狀態(tài)轉(zhuǎn)換到 RUNNABLE。

　　第三種場(chǎng)景，調(diào)用 LockSupport.park() 方法。其中的 LockSupport 對(duì)象，也許你有點(diǎn)陌生，其實(shí) Java 并發(fā)包中的鎖，都是基于它實(shí)現(xiàn)的。調(diào)用 LockSupport.park() 方法，當(dāng)前線(xiàn)程會(huì)阻塞，線(xiàn)程的狀態(tài)會(huì)從 RUNNABLE 轉(zhuǎn)換到 WAITING。調(diào)用 LockSupport.unpark(Thread thread) 可喚醒目標(biāo)線(xiàn)程，目標(biāo)線(xiàn)程的狀態(tài)又會(huì)從 WAITING 狀態(tài)轉(zhuǎn)換到 RUNNABLE。

　　3. RUNNABLE 與 TIMED_WAITING 的狀態(tài)轉(zhuǎn)換

　　有五種場(chǎng)景會(huì)觸發(fā)這種轉(zhuǎn)換，其中：

　　調(diào)用帶超時(shí)參數(shù)的 Thread.sleep(long millis) 方法。

　　獲得 synchronized 隱式鎖的線(xiàn)程，調(diào)用帶超時(shí)參數(shù)的 Object.wait(long timeout) 方法。

　　調(diào)用帶超時(shí)參數(shù)的 Thread.join(long millis) 方法。

　　調(diào)用帶超時(shí)參數(shù)的 LockSupport.parkNanos(Object blocker, long deadline) 方法。

　　調(diào)用帶超時(shí)參數(shù)的 LockSupport.parkUntil(long deadline) 方法。

　　4. 從 NEW 到 RUNNABLE 的狀態(tài)

　　Java 剛創(chuàng)建出來(lái)的 Thread 對(duì)象就是 NEW 狀態(tài)，而創(chuàng)建 Thread 對(duì)象主要有兩種方法：

　　首先，第一種方式是繼承 Thread 對(duì)象，重寫(xiě) run() 方法

　　// 自定義線(xiàn)程對(duì)象

　　class ApplicationThread extends Thread {

　　public void run() {

　　// 線(xiàn)程需要執(zhí)行的代碼

　　......

　　}

　　}

　　// 創(chuàng)建線(xiàn)程對(duì)象

　　ApplicationThread applicationThread = new ApplicationThread();

　　其次，另一種方式是實(shí)現(xiàn) Runnable 接口，重寫(xiě) run() 方法，并將該實(shí)現(xiàn)類(lèi)作為創(chuàng)建 Thread 對(duì)象的參數(shù)

　　// 實(shí)現(xiàn)Runnable接口

　　class ApplicationThread implements Runnable {

　　@Override

　　public void run() {

　　// 線(xiàn)程需要執(zhí)行的代碼

　　......

　　}

　　}

　　// 創(chuàng)建線(xiàn)程對(duì)象

　　Thread thread = new Thread(new ApplicationThread());

　　NEW 狀態(tài)的線(xiàn)程，不會(huì)被操作系統(tǒng)調(diào)度，因此不會(huì)執(zhí)行。Java 線(xiàn)程要執(zhí)行，就必須轉(zhuǎn)換到 RUNNABLE 狀態(tài)。從 NEW 狀態(tài)轉(zhuǎn)換到 RUNNABLE 狀態(tài)很簡(jiǎn)單，只要調(diào)用線(xiàn)程對(duì)象的 start() 方法即可。

　　5. 從 RUNNABLE 到 TERMINATED

　　線(xiàn)程執(zhí)行完 run() 方法后，會(huì)自動(dòng)轉(zhuǎn)換到 TERMINATED 狀態(tài)，當(dāng)然如果執(zhí)行 run() 方法的時(shí)候異常拋出，也會(huì)導(dǎo)致線(xiàn)程終止。有時(shí)候我們需要強(qiáng)制中斷 run() 方法的執(zhí)行。

　　一般來(lái)說(shuō)， run() 方法訪(fǎng)問(wèn)一個(gè)很慢的網(wǎng)絡(luò)，我們等不下去了，想終止怎么辦呢?

　　Java 的 Thread 類(lèi)里面倒是有個(gè) stop() 方法，不過(guò)已經(jīng)標(biāo)記為 @Deprecated，所以不建議使用了。正確的姿勢(shì)其實(shí)是調(diào)用 interrupt() 方法。

　　那么，stop() 和 interrupt() 方法的主要區(qū)別是什么呢?

　　stop() 方法會(huì)真的殺死線(xiàn)程，不給線(xiàn)程喘息的機(jī)會(huì)，如果線(xiàn)程持有 ReentrantLock 鎖，被 stop() 的線(xiàn)程并不會(huì)自動(dòng)調(diào)用 ReentrantLock 的 unlock() 去釋放鎖，那其他線(xiàn)程就再也沒(méi)機(jī)會(huì)獲得 ReentrantLock 鎖，這實(shí)在是太危險(xiǎn)了。所以該方法就不建議使用了，類(lèi)似的方法還有 suspend() 和 resume() 方法，這兩個(gè)方法同樣也都不建議使用。

　　interrupt() 方法僅僅是通知線(xiàn)程，線(xiàn)程有機(jī)會(huì)執(zhí)行一些后續(xù)操作，同時(shí)也可以無(wú)視這個(gè)通知。

　　被 interrupt 的線(xiàn)程，是怎么收到通知的呢?

　　一種是異常：

　　線(xiàn)程 A 處于 WAITING、TIMED_WAITING 狀態(tài)時(shí)，如果其他線(xiàn)程調(diào)用線(xiàn)程 A 的 interrupt() 方法，會(huì)使線(xiàn)程 A 返回到 RUNNABLE 狀態(tài)，同時(shí)線(xiàn)程 A 的代碼會(huì)觸發(fā) InterruptedException 異常。上面我們提到轉(zhuǎn)換到 WAITING、TIMED_WAITING 狀態(tài)的觸發(fā)條件，都是調(diào)用了類(lèi)似 wait()、join()、sleep() 這樣的方法，我們看這些方法的簽名，發(fā)現(xiàn)都會(huì) throws InterruptedException 這個(gè)異常。這個(gè)異常的觸發(fā)條件就是：其他線(xiàn)程調(diào)用了該線(xiàn)程的 interrupt() 方法。

　　當(dāng)線(xiàn)程 A 處于 RUNNABLE 狀態(tài)時(shí)，并且阻塞在 java.nio.channels.InterruptibleChannel 上時(shí)，如果其他線(xiàn)程調(diào)用線(xiàn)程 A 的 interrupt() 方法，線(xiàn)程 A 會(huì)觸發(fā) java.nio.channels.ClosedByInterruptException 這個(gè)異常;而阻塞在 java.nio.channels.Selector 上時(shí)，如果其他線(xiàn)程調(diào)用線(xiàn)程 A 的 interrupt() 方法，線(xiàn)程 A 的 java.nio.channels.Selector 會(huì)立即返回。

　　另一種是主動(dòng)檢測(cè)：

　　如果線(xiàn)程處于 RUNNABLE 狀態(tài)，并且沒(méi)有阻塞在某個(gè) I/O 操作上，例如中斷計(jì)算圓周率的線(xiàn)程 A，這時(shí)就得依賴(lài)線(xiàn)程 A 主動(dòng)檢測(cè)中斷狀態(tài)了。

　　如果其他線(xiàn)程調(diào)用線(xiàn)程 A 的 interrupt() 方法，那么線(xiàn)程 A 可以通過(guò) isInterrupted() 方法，檢測(cè)是不是自己被中斷。

　　更多關(guān)于“java培訓(xùn)”的問(wèn)題，歡迎咨詢(xún)千鋒教育在線(xiàn)名師。千鋒教育多年辦學(xué)，課程大綱緊跟企業(yè)需求，更科學(xué)更嚴(yán)謹(jǐn)，每年培養(yǎng)泛IT人才近2萬(wàn)人。不論你是零基礎(chǔ)還是想提升，都可以找到適合的班型，千鋒教育隨時(shí)歡迎你來(lái)試聽(tīng)。