白話說Java線程（二）—讓線程優(yōu)雅的停下來

作者：張旸 2017-11-22 15:11:33

當(dāng)開啟一起線程去執(zhí)行任務(wù)之后，如果需要被停止，意味著它將放棄當(dāng)前正在進(jìn)行的操作。而在 Java 中，停止一個(gè)線程并不像 return 一個(gè)方法一樣干脆利落，想要安全的停止線程，需要一些跟優(yōu)雅的技巧。

[[210879]]

一、前言

繼續(xù)接之前 Java 多線程的內(nèi)容，之前講解了 Java 下多線程的使用，有興趣的可以先看看《白話說 Java 線程（一）之讓線程先跑起來》。但是能舞的起來是徒弟，能停的優(yōu)雅才是師傅。

接下來讓我們看看，如何優(yōu)雅的停止一個(gè)線程。

二、全的停止線程

2.1、安全停止涉及到的方法

如果想要安全的停止一個(gè)線程，需要借助 Thread.interrupt() 方法，它的本意是停止、終止的意思，但是實(shí)際上，它并不會(huì)直接終止掉一個(gè)正在運(yùn)行的進(jìn)程，而是在當(dāng)前線程中，打一個(gè)需要"被停止"的標(biāo)簽，而是否停止應(yīng)該由當(dāng)前線程自己決定，所以這也決定了我們需要在編寫 Thread 或者 Runnable 代碼的時(shí)候，有更高的要求，要明確自己如何被安全的停止。

interrupt() 的解釋確實(shí)挺多，接下來看看它是如何使用的。

既然 interrupt() 只是為我們對當(dāng)前線程做了一個(gè)簡單的停止標(biāo)記，而 JDK 同時(shí)也為我們提供了獲取這個(gè)標(biāo)記值的 API。

Thread.interrupted()：檢查當(dāng)前運(yùn)行這段代碼的線程，是否已經(jīng)被停止。
this.isInterrupted()：檢查當(dāng)前 this 指定的線程，是否已經(jīng)被停止。

通過源碼可以看到它們的區(qū)別，interrupted() 是一個(gè) static 的方法，并且操作的是當(dāng)前代碼運(yùn)行的當(dāng)前線程，而 isInterrupted() 方法缺失操作的是指定線程。它們最終都會(huì)調(diào)用 isInterrupted(boolean) 的方法。

再來看看這個(gè)方法。

可以看到，這個(gè)方法是一個(gè) native 的方法，參數(shù)表示是否需要清理這個(gè) Interrupted 的狀態(tài)。

2.2、具體看看這些方法的用處

舉個(gè)例子看看如何區(qū)分這兩個(gè)方法：

1 為停止，表示檢查的是 mt 這個(gè)線程，而 2 為沒停止，是因?yàn)闄z查的是當(dāng)前運(yùn)行環(huán)境的線程，即為主線程。

這個(gè)例子本身沒問題，也講清楚了原本的意思。但是實(shí)際上，interrupt() 方法和 interrupted() 方法并不是線程安全的，也就是說，如果使用 interrupt() 方法停止了一個(gè)線程，立即使用 interrupted() 方法去檢查，可能會(huì)回去到還沒有被停止的結(jié)果。

前面介紹到，interrupt() 和 isInterrupted() 方法最終都會(huì)調(diào)用一個(gè) native 的 isInterrupted(boolean) 的方法，這個(gè)方法的參數(shù)主要是為了確定是否需要清理 interrupted 的狀態(tài)。

下面舉兩個(gè)例子就清楚了。

先看看 Thread.interrupted()。

可以看到，***次標(biāo)記為 true，但是獲取完之后，立即就被清理掉了 interrupt 狀態(tài)，再去獲取，就標(biāo)記為 false。再看看 isInterrupted() ，它是不會(huì)清理掉狀態(tài)的。

2.3、需要安全停止的線程

那么繼續(xù)改造一下上面的例子，如果想在線程被停止之后，立即停止掉循環(huán)，就可以在循環(huán)中，每次調(diào)用都檢查一下當(dāng)前線程是否已經(jīng)被停止了。如果被停止了，直接 return 出去，或者做一些清理工作再退出。

2.4、在sleep的時(shí)候，停止線程會(huì)發(fā)生什么

當(dāng)前線程有可能在運(yùn)行狀態(tài)，也可能在 sleep 的狀態(tài)，如果在 sleep 的狀態(tài)下，interrupt 一個(gè)線程，會(huì)發(fā)生什么？

從調(diào)用 sleep 的時(shí)候就應(yīng)該發(fā)現(xiàn)，它是會(huì)拋出一個(gè) InterruptedException 異常的，這里就是專門為了捕捉在 sleep 的時(shí)候，被 interrupt 的情況。如果觸發(fā)，將進(jìn)入 catch。并且置換 interrupt 狀態(tài)為 false ，所以這里觸發(fā)了到 sleep 的 catch 的時(shí)候，一定要有后續(xù)的操作，不要再依賴那兩個(gè)判斷線程終止的方法來判斷了。

三、如何非安全的停止線程

既然推薦用安全的方式來停止線程，那么不安全的方式又需要怎么做呢？不安全的方式其實(shí)本身也不推薦使用，但是研究一下為什么不安全也有利于我們理解線程安全。

不安全的方式，就涉及到 Thread 的幾個(gè)已經(jīng)被標(biāo)記為 @Deprecated 的方法，就是說，已經(jīng)被廢棄了，可能引發(fā)不可預(yù)料的問題，不推薦使用。

這個(gè)方法就是 stop() 方法，和名稱一樣，它的作用就是停止線程。

stop() 能不能做到立即停止線程？

能，除了它的一些不可能預(yù)料的數(shù)據(jù)問題之外，stop() 方法真的非常的好用，停止線程可以做到簡單直接，直接被停止之后，后面的代碼根本不會(huì)得到執(zhí)行，這樣會(huì)導(dǎo)致一些清理工作沒法完成，并且 stop() 會(huì)直接釋放當(dāng)前獲取到的鎖，而如果當(dāng)前正好在修改加鎖的數(shù)據(jù)的時(shí)候，被強(qiáng)制停止了，就會(huì)導(dǎo)致數(shù)據(jù)被改了一半，導(dǎo)致數(shù)據(jù)不一致的情況。

既然不推薦使用，那就簡單舉個(gè)例子，不再寫 demo 了。

假設(shè)一個(gè)人做生意，賣書，庫房里存了需要賣的書，每次的流程是從庫房里拿出來一本書，賣出去之后，把錢存入銀行賬戶，再去取一本書繼續(xù)賣。假設(shè)有一天，這個(gè)人從庫房取了一本書賣出去了，正在去銀行存錢的路上，被警察逮捕了（stop），接下來他就沒辦法完成去銀行存錢的任務(wù)了。這個(gè)時(shí)候?qū)膸齑婧豌y行賬戶上的金額，就對不上了，因?yàn)槌鰩炝艘槐緯睕]有相應(yīng)的金錢入賬。這樣的一個(gè)數(shù)據(jù)不一致，就是線程不安全。當(dāng)然，實(shí)際項(xiàng)目中，這種數(shù)據(jù)操作都是以事務(wù)的形式存在的，一旦失敗就會(huì)回滾事務(wù)，讓數(shù)據(jù)保持一致。

有一點(diǎn)需要注意一下，stop() 方法的時(shí)候，會(huì)觸發(fā) ThreadDead 異常，但是它不需要被顯示 Catch 住，大家只需要知道有這么個(gè)概念就可以了。

四、結(jié)語

到現(xiàn)在基本上就講解清楚了子線程的創(chuàng)建和停止。既然已經(jīng)被廢棄的方法，***還是不要去使用它，建議使用安全的方式去停止線程。