中止一個線程意味着在任務處理完任務以前停掉正在作的操做,也就是放棄當前的操做。中止一個線程能夠用Thread.stop()方法,但最好不要用它。雖然它確實能夠中止一個正在運行的線程,可是這個方法是不安全的,並且是已被廢棄的方法。java
在java中有如下3種方法能夠終止正在運行的線程:面試
interrupt()方法的使用效果並不像for+break語句那樣,立刻就中止循環。調用interrupt方法是在當前線程中打了一箇中止標誌,並非真的中止線程。安全
輸出結果:markdown
Thread.java類中提供了兩種方法:學習
那麼這兩個方法有什麼圖區別呢?測試
咱們先來看看this.interrupted()方法的解釋:測試當前線程是否已經中斷,當前線程是指運行this.interrupted()方法的線程。this
運行結果:spa
??
??
複製代碼
類Run.java中雖然是在thread對象上調用如下代碼:thread.interrupt(), 後面又使用線程
(" 1??" + ());
(" 2??" + ());
複製代碼
來判斷thread對象所表明的線程是否中止,但從控制檯打印的結果來看,線程並未中止,這也證實了interrupted()方法的解釋,測試當前線程是否已經中斷。這個當前線程是main,它從未中斷過,因此打印的結果是兩個false.3d
如何使main線程產生中斷效果呢?
運行效果爲:
??
??
複製代碼
方法interrupted()的確判斷出當前線程是不是中止狀態。但爲何第2個布爾值是false呢?官方幫助文檔中對interrupted方法的解釋:
測試當前線程是否已經中斷。線程的中斷狀態由該方法清除。
換句話說,若是連續兩次調用該方法,則第二次調用返回false。
下面來看一下inInterrupted()方法。
運行結果:
??
??
複製代碼
isInterrupted()併爲清除狀態,因此打印了兩個true。
有了前面學習過的知識點,就能夠在線程中用for語句來判斷一下線程是不是中止狀態,若是是中止狀態,則後面的代碼再也不運行便可:
運行結果:
上面的示例雖然中止了線程,但若是for語句下面還有語句,仍是會繼續運行的。看下面的例子:
使用Run.java執行的結果是:
如何解決語句繼續運行的問題呢?看一下更新後的代碼:
使用Run.java運行的結果以下:
若是線程在sleep()狀態下中止線程,會是什麼效果呢?
使用Run.java運行的結果是:
從打印的結果來看, 若是在sleep狀態下中止某一線程,會進入catch語句,而且清除中止狀態值,使之變爲false。
前一個實驗是先sleep而後再用interrupt()中止,與之相反的操做在學習過程當中也要注意:
運行結果:
使用stop()方法中止線程則是很是暴力的。
運行結果:
調用stop()方法時會拋出java.lang.ThreadDeath異常,可是一般狀況下,此異常不須要顯示地捕捉。
stop()方法以及做廢,由於若是強制讓線程中止有可能使一些清理性的工做得不到完成。另一個狀況就是對鎖定的對象進行了解鎖,致使數據得不到同步的處理,出現數據不一致的問題。
使用stop()釋放鎖將會給數據形成不一致性的結果。若是出現這樣的狀況,程序處理的數據就有可能遭到破壞,最終致使程序執行的流程錯誤,必定要特別注意:
public class SynchronizedObject { private String name = "a"; private String password = "aa"; public synchronized void printString(String name, String password){ try { this.name = name; Thread.sleep(100000); this.password = password; } catch (InterruptedException e) { e.printStackTrace(); } } public String getName() { return name; } public void setName(String name) { this.name = name; } public String getPassword() { return password; } public void setPassword(String password) { this.password = password; }}public class MyThread extends Thread { private SynchronizedObject synchronizedObject; public MyThread(SynchronizedObject synchronizedObject){ this.synchronizedObject = synchronizedObject; } public void run(){ synchronizedObject.printString("b", "bb"); }}public class Run { public static void main(String args\[\]) throws InterruptedException { SynchronizedObject synchronizedObject = new SynchronizedObject(); Thread thread = new MyThread(synchronizedObject); thread.start(); Thread.sleep(500); thread.stop(); System.out.println(synchronizedObject.getName() + " " + synchronizedObject.getPassword()); }}
複製代碼
輸出結果:
b aa
複製代碼
因爲stop()方法以及在JDK中被標明爲「過時/做廢」的方法,顯然它在功能上具備缺陷,因此不建議在程序張使用stop()方法。
將方法interrupt()與return結合使用也能實現中止線程的效果:
public class MyThread extends Thread { public void run(){ while (true){ if(this.isInterrupted()){ System.out.println("線程被中止了!"); return; } System.out.println("Time: " + System.currentTimeMillis()); } }}public class Run { public static void main(String args\[\]) throws InterruptedException { Thread thread = new MyThread(); thread.start(); Thread.sleep(2000); thread.interrupt(); }}
複製代碼
輸出結果:
...Time: 1467072288503Time: 1467072288503Time: 1467072288503線程被中止了!
複製代碼
不過仍是建議使用「拋異常」的方法來實現線程的中止,由於在catch塊中還能夠將異常向上拋,使線程中止事件得以傳播。