java如何正確停止一個線程

更新時間：2019-10-25 11:38:08 來源：動力節點瀏覽2485次

　如何停止java的線程一直是一個開發多線程程序常遇到的一個問題。也有好多同學問過，所以今天動力節點java培訓機構小編在這里總結一下希望可以讓更多的人知道在java中如何安全的結束一個正在運行的線程。

　　在Java的多線程編程中，java.lang.Thread類型包含了一些列的方法start(), stop(), stop(Throwable) and suspend(), destroy() and resume()。通過這些方法，我們可以對線程進行方便的操作，但是這些方法中，只有start()方法得到了保留。

　　那么，我們究竟應該如何停止線程呢?這里我們介紹兩種方法：

　　1、使用共享變量的方式

　　在這種方式中，之所以引入共享變量，是因為該變量可以被多個執行相同任務的線程用來作為是否中斷的信號，通知中斷線程的執行。

public class ThreadFlag extends Thread

{

public volatile boolean exit = false;

public void run()

{

while (!exit);

}

public static void main(String[] args) throws Exception

{

ThreadFlag thread = new ThreadFlag();

thread.start();

sleep(3000); // 主線程延遲3秒

thread.exit = true; // 終止線程thread

thread.join();

System.out.println("線程退出!");

}

　　在上面代碼中定義了一個退出標志exit，當exit為true時，while循環退出，exit的默認值為false。在定義exit時，使用了一個Java關鍵字volatile，這個關鍵字的目的是使exit同步，也就是說在同一時刻只能由一個線程來修改exit的值。

　　建議使用如下的方法來停止線程：

private volatile Thread blinker;

public void stop() {

blinker = null;

}

public void run() {

Thread thisThread = Thread.currentThread();

while (blinker == thisThread) {

try {

thisThread.sleep(interval);

} catch (InterruptedException e){

}

repaint();

}

　　2、使用interrupt方法終止線程

　　如果一個線程由于等待某些事件的發生而被阻塞，又該怎樣停止該線程呢?

　　這種情況經常會發生，比如當一個線程由于需要等候鍵盤輸入而被阻塞，或者調用Thread.join()方法，或者Thread.sleep()方法，在網絡中調用ServerSocket.accept()方法，或者調用了DatagramSocket.receive()方法時，都有可能導致線程阻塞，使線程處于處于不可運行狀態時，即使主程序中將該線程的共享變量設置為true，但該線程此時根本無法檢查循環標志，當然也就無法立即中斷。

　　這里我們給出的建議是，不要使用stop()方法，而是使用Thread提供的interrupt()方法，因為該方法雖然不會中斷一個正在運行的線程，但是它可以使一個被阻塞的線程拋出一個中斷異常，從而使線程提前結束阻塞狀態，退出堵塞代碼。

class MyThread extends Thread {

volatile boolean stop = false;

public void run() {

while (!stop) {

System.out.println(getName() + " is running");

try {

sleep(1000);

}catch (InterruptedException e) {

System.out.println("week up from blcok...");

stop = true; // 在異常處理代碼中修改共享變量的狀態

}

System.out.println(getName() + " is exiting...");

}

class InterruptThreadDemo3 {

public static void main(String[] args) throws InterruptedException {

MyThread m1 = new MyThread();

System.out.println("Starting thread...");

m1.start();

Thread.sleep(3000);

System.out.println("Interrupt thread...: " + m1.getName());

m1.stop = true; // 設置共享變量為true

m1.interrupt(); // 阻塞時退出阻塞狀態

Thread.sleep(3000); // 主線程休眠3秒以便觀察線程m1的中斷情況

System.out.println("Stopping application...");

}

　　注意：在Thread類中有兩個方法可以判斷線程是否通過interrupt方法被終止。一個是靜態的方法interrupted()，一個是非靜態的方法isInterrupted()，這兩個方法的區別是interrupted用來判斷當前線是否被中斷，而isInterrupted可以用來判斷其他線程是否被中斷。

timg (10).jpg