2. 程式人生 > >Java中如何結束執行緒

Java中如何結束執行緒

阿新 • • 發佈：2019-01-02
一般來說執行緒執行完run()之後就自動結束了，不過有些時候我們需要執行緒不停的做一些事情，也就是使用while迴圈，那麼這時候該如何停止執行緒呢？
這個問題需要分情況來討論，如果執行緒做的事情不是耗時的，那麼只需要使用一個標誌即可，具體的程式碼如下：
  1. class MyThread extends Thread {         
  2.     privatevolatileboolean isStop = false;      
  3.     publicvoid run() {  
  4.         while (!isStop) {  
  5.             System.out.println("do something"
    );  
  6.         }  
  7.     }  
  8.     publicvoid setStop() {  
  9.         isStop = true;  
  10.     }        
  11. }  
如果需要退出時，呼叫setStop()即可。這裡使用了一個Java關鍵字volatile，這個關鍵字的目的是如果修改了isStop的值，那麼在while迴圈中可以立即讀取到修改後的值，關於volatile的詳細介紹可以參考我的另一篇博文java執行緒同步volatile與synchronized。
如果執行緒做的事情是耗時或者說阻塞的（如呼叫了sleep，同步鎖的wait，socket的receiver，accept等方法），那麼就需要用到interrupt()了，呼叫該函式時會丟擲InterruptedException異常，程式碼中通過捕獲該異常，然後break出迴圈，就可以了。程式碼如下：

  1. class MyThread extends Thread {    
  2.     privatevolatileboolean isStop = false;      
  3.     publicvoid run() {  
  4.         while (!isStop) {  
  5.             try {  
  6.                 System.out.println("do something");  
  7.                 Thread.sleep(1000);  
  8.             } catch (InterruptedException e) {  
  9.                 e.printStackTrace();  
  10.                 break;//如果沒有這一句，而且不呼叫setStop()，執行緒並不會結束，需要特別注意一下
  11.             }  
  12.         }  
  13.     }  
  14.     publicvoid setStop() {  
  15.         isStop = true;  
  16.     }        
  17. }    
  18. publicclass Tes1 {  
  19.     publicstaticvoid main(String[] args) {    
  20.         MyThread t1 = new MyThread();  
  21.         t1.start();  
  22.         try {  
  23.             Thread.sleep(10);  
  24.             t1.setStop();  
  25.             t1.interrupt();  
  26.         } catch (InterruptedException e) {  
  27.             // TODO Auto-generated catch block
  28.             e.printStackTrace();  
  29.         }  
  30.     }  
  31. }  
這裡既然說到了interrupt()，那麼就不得不提另外兩個函式：interrupted()和isInterrupted。看下這兩個函式的作用：
public static boolean interrupted() 
測試當前執行緒是否已經中斷，並且清除執行緒的中斷狀態。
public boolean isInterrupted() 
測試執行緒是否已經中斷，執行緒的中斷狀態不受該方法的影響。 
這兩個函式的返回值含義： 
如果當前執行緒已經中斷，則返回 true；否則返回 false。 
其實當執行緒阻塞並且呼叫了interrupt()時，不止是丟擲InterruptedException異常還會呼叫interrupted()來清除執行緒的中斷狀態，所以在catch裡面呼叫isInterrupted()會返回false。
為了更好的理解這兩個函式，我們看個例子：
  1. class MyThread extends Thread {         
  2.     privateint counter = 0;      
  3.     publicvoid run() {    
  4.         boolean done = false;    
  5.         try{    
  6.             Thread.sleep(10);  
  7.         }catch(InterruptedException ie){    
  8.             ie.printStackTrace();    
  9.             return;  
  10.         }  
  11.         while (counter < 2000 &&!done) {    
  12.             System.out.println(counter++ + " in thread isInterrupted() "+isInterrupted());  
  13.             if(isInterrupted()==true){    
  14.                 try{  
  15.                     System.out.println("in thread after interrupted() "+isInterrupted());  
  16.                     sleep(100);  
  17.                     break;  
  18.                 }catch(InterruptedException ie){    
  19.                     ie.printStackTrace();  
  20.                     break;  
  21.                 }    
  22.             }    
  23.         }    
  24.     }         
  25. }    
  26. publicclass Tes1 {  
  27.     publicstaticvoid main(String[] args) {    
  28.         final MyThread t1 = new MyThread();    
  29.         t1.start();    
  30.         new Timer(true).schedule(new TimerTask() {    
  31.             publicvoid run() {    
  32.                 System.out.println("exec interrupt");    
  33.                 t1.interrupt();  
  34.                 System.out.println("in timer isInterrupted() "+t1.isInterrupted());    
  35.             }    
  36.         }, 20);  
  37.     }    
  38. }  
執行效果如下（每一次執行列印的都不一樣，因為沒有做執行緒同步）：
...
1300 in thread isInterrupted() false
exec interrupt
in timer isInterrupted() true
1301 in thread isInterrupted() true
in thread after interrupted() true
java.lang.InterruptedException: sleep interrupted
at java.lang.Thread.sleep(Native Method)
at com.example.wd.MyThread.run(Tes1.java:21)
還可能是這樣：
...
1568 in thread isInterrupted() false
exec interrupt
in thread after interrupted() true
in timer isInterrupted() true
java.lang.InterruptedException: sleep interrupted
at java.lang.Thread.sleep(Native Method)
at com.example.wd.MyThread.run(Tes1.java:21)
由於在sleep時執行了interrupt()所以會丟擲異常。
如果把if(isInterrupted()==true)改成if(Thread.interrupted()==true)那麼列印的結果就不同了，如下：
...
1582 in thread isInterrupted() false
exec interrupt
in timer isInterrupted() true
in thread after interrupted() false
還可能是這樣：
...
1771 in thread isInterrupted() false
exec interrupt
in timer isInterrupted() true
1772 in thread isInterrupted() false
in thread after interrupted() false
也可能是這樣：
...
476 in thread isInterrupted() false
in thread after interrupted() false
in timer isInterrupted() false
雖然執行了interrupt()，但是由於Thread.interrupted()可以清除中斷，所以並不會丟擲異常。
前面我們針對執行緒是否耗時，給出了停止執行緒的方法，其實還有一個辦法那就是使用thread.stop()來強行終止執行緒，不過這個由於該方法不安全已經廢棄掉了，因為他有下面兩個缺陷：
1. 立即丟擲ThreadDeath異常，線上程的run()方法內，任何一點都有可能丟擲ThreadDeath異常，包括在catch或finally語句中。
2. 釋放該執行緒所持有的所有的鎖。
好了，關於執行緒如何停止的問題到這裡就圓滿收官了，大家有什麼問題歡迎留言討論。

相關推薦

Java中結束執行緒的三種方式

原文地址：http://blog.csdn.net/anhuidelinger/article/details/11746365     有三種方法可以使終止執行緒。      1.  使用退出標誌，使執行緒正常退出，也就是當run方法完成後執行緒終止。      2.  使用stop方法強行終止執行緒（

Java中停止執行緒

一.停止執行緒會帶來什麼？ 對於單執行緒中，停止單執行緒就是直接使用關鍵字return或者break，但是在停止多執行緒時是讓執行緒在完成任務前去開啟另外一條執行緒，必須放棄當前任務，而這個過程是不可預測，所以必須去做好防備。 二.認識停止執行緒的幾個方法  2.1三個被棄用的

java中多執行緒一定快嗎?看完就知道!!!

理解上下文切換   即使是單核處理器也支援多執行緒執行程式碼,CPU通過每個執行緒分配CPU時間片來實現這個機制.時間片是CPU分配給多個執行緒的時間,因為時間片非常短,所以CPU通過不停的切換執行緒執行,讓我們感覺多個執行緒是同時執行的,時間片一般是幾十毫秒(ms).  

深入理解Java中停止執行緒

一.停止執行緒會帶來什麼？ 對於單執行緒中，停止單執行緒就是直接使用關鍵字return或者break，但是在停止多執行緒時是讓執行緒在完成任務前去開啟另外一條執行緒，必須放棄當前任務，而這個過程是不可預測，所以必須去做好防備。 二.認識停止執行緒的幾個方法  2.1三個被棄用的方法 &n

Java中的執行緒池及其實現類ThreadPoolExecutor

前言：像我們連線資料庫一樣，需要不斷地建立連線，銷燬連線，如果都是人為地一個個建立和銷燬的話會很費勁，所以就誕生了資料庫連線池，執行緒池的產生也是同樣的道理。 執行緒池預先建立了若干數量的執行緒，並且不能由使用者直接對執行緒的建立進行控制，在這個前提下重複使用固定或較為固定數目的執行緒來完成任務

【小家java】Java中主執行緒（父執行緒）與子執行緒的通訊和聯絡

相關閱讀 【小家java】java5新特性（簡述十大新特性） 重要一躍 【小家java】java6新特性（簡述十大新特性） 雞肋升級 【小家java】java7新特性（簡述八大新特性） 不溫不火 【小家java】java8新特性（簡述十大新特性） 飽受讚譽 【小家java】java9

【小家java】Java中的執行緒池，你真的用對了嗎？（教你用正確的姿勢使用執行緒池）

相關閱讀 【小家java】java5新特性（簡述十大新特性） 重要一躍 【小家java】java6新特性（簡述十大新特性） 雞肋升級 【小家java】java7新特性（簡述八大新特性） 不溫不火 【小家java】java8新特性（簡述十大新特性） 飽受讚譽 【小家java】java9

如何在JAVA中建立執行緒池

ExecutorService 今天小編要分享的是關於執行緒池， 想必接觸到併發處理的朋友都有用到執行緒池， 當我們訪問伺服器的量達到伺服器一定量的時候， 比如幾百萬幾千萬，很容易造成伺服器崩掉， 如果使用執行緒進行併發處理，將使用的執行緒進行回收在使用，就減小了伺服器的壓力

【Java併發】Java中的執行緒池

Java中的執行緒池 執行流程 執行緒池的建立 提交任務 關閉執行緒池 參考 執行流程 處理流程如下： execute()方法執行示意圖如下： 執行緒池的建立 corePoolSize：執行緒池

java 中的執行緒

1.概念: 什麼是程序？ 　　概念：在計算機中執行的軟體，是作業系統中最基礎的組成部分 。程序是容器，裡面裝的都是執行緒。 什麼是執行緒？ 　　概念：就是執行在程序中的一段程式碼，是程序中最小組織單元。 注意：　　1.一個程序中至少要有一個執行緒，該執行緒必須是主執行緒　　2.一個程序中可以有多個執行緒

Java中的執行緒之執行緒間的通訊

                                         兩個

JAVA中的執行緒池的理解

為了更好的理解，首先來看一篇JAVA中的執行緒池介紹： 一、簡介 執行緒池類為 java.util.concurrent.ThreadPoolExecutor，常用構造方法為： ThreadPoolExecutor(int corePoolSize, int maxim

Java中的執行緒Thread方法之---suspend()和resume()

案例一：(通過打斷點除錯) package com.threadstop.demo; import java.util.Iterator; import java.util.Map; import java.util.Map.Entry; import java.u

Java中多執行緒併發體系知識點彙總

一、多執行緒 1、作業系統有兩個容易混淆的概念，程序和執行緒。 程序：一個計算機程式的執行例項，包含了需要執行的指令；有自己的獨立地址空間，包含程式內容和資料；不同程序的地址空間是互相隔離的；程序擁有各種資源和狀態資訊，包括開啟的檔案、子程序和訊號處理。 執行緒：表示程

java中建立執行緒的三種方法以及區別

Java使用Thread類代表執行緒，所有的執行緒物件都必須是Thread類或其子類的例項。Java可以用三種方式來建立執行緒，如下所示： 1）繼承Thread類建立執行緒 2）實現Runnable介面建立執行緒 3）使用Callable和Future建立執行緒 下面

java中建立執行緒

Java使用Thread類代表執行緒，所有的執行緒物件都必須是Thread類或其子類的例項。Java可以用三種方式來建立執行緒，如下所示： 1、繼承Thread類建立執行緒 定義Thread類的子類，並重寫該類的run()方法，建立Thread子類的例項，呼叫執行緒的start()方法啟

Java中的執行緒通訊、執行緒組、未處理的執行緒異常

執行緒通訊 傳統的執行緒通訊 假設現在系統中有兩個執行緒，這兩個執行緒分別代表存款者和取錢者，而系統有一種特殊的要求，系統要求存款者和取錢者不斷地重複存款、取錢的動作，而且要求每當存款者將錢存入指定賬戶後，取錢者就立即取錢。不允許存款者和取錢者操作連續超過兩次。 為了實現這種功能

如何在JAVA中建立:執行緒池

ExecutorService 今天小編要分享的是關於執行緒池， 想必接觸到併發處理的朋友都有用到執行緒池， 當我們訪問伺服器的量達到伺服器一定量的時候， 比如幾百萬幾千萬，很容易造成伺服器崩掉， 如果使用執行緒進行併發處理，將使用的執行緒進行回收在使用，就減小了伺

java中建立執行緒的方法以及區別

Java使用Thread類代表執行緒，所有的執行緒物件都必須是Thread類或其子類的例項。Java可以用四種方式來建立執行緒，如下所示： 1）繼承Thread類建立執行緒 2）實現Runnable介面建立執行緒 3）使用Callable和Future建立執

Java中排程執行緒池ScheduledThreadPoolExecutor原理探究

一、 前言 前面講解過Java中執行緒池ThreadPoolExecutor原理探究，ThreadPoolExecutor是Executors中一部分功能，下面來介紹另外一部分功能也就是ScheduledThreadPoolExecutor的實現，後者是一個可以在一定延遲時候或者定時進行任務排