Java關閉線程的安全方法

Java之前有一個api方法可以直接關閉線程，stop()，由於這個方法是強制性地關閉線程，有的時候會發生錯誤，之后就取消了，現在可用的方法主要有兩種：

1、  在線程中加入一個成員變量，當一個flag使用。在線程run()方法中輪流去檢查這個變量，變量變化時就退出這個線程。代碼示例如下：

 

public class StopThread extends Thread {
    private boolean _run = true;
    public void stopThread(boolean run) {
        this._run = !run;
    }
    @Override
    public void run() {
        while(_run) {
            // 數據處理
        }
    }
}

 

 

2、  第一個方法雖然可以處理好，不過，在有阻塞線程的語句的時候往往不能處理好，因為線程被阻塞了，它便不能核查成員變量，就不能停止。比如, 涉及到Socket的阻塞語句server.accept().要使用某種機制使得阻塞線程更早地退出被阻塞的狀態，這個時候可以使用Thread.interrupt()方法。Interrupt()方法只能解決跑出InterruptedException異常的阻塞。而interrupt()並不是關閉阻塞線程，而且解除阻塞。上一個例子：

 

public class BlockTask extends Thread {
    @Override
    public void run() {
        try {
            sleep(10000);
        } catch (InterruptedException e) {
        }
    }
    public static void main(String[] args)throws Exception {
        BlockTask task = new BlockTask();
        task.start();
        Thread.sleep(1000);
        task.interrupt();
    }

 

 

3、上面說了，interrupt()只能解決InterruptedException的阻塞的線程，那么遇到一些其他的io阻塞怎么處理呢？這個時候java都會提供相應的關閉阻塞的辦法。例如，服務器可能需要等待一個請求（request），又或者，一個網絡應用程序可能要等待遠端主機的響應,這個時候可以使用套接字close()方法。

 

public class SocketTask extends Thread {
    private volatile ServerSocket server; 
    public void stopTask(){
        try {
            if(server!=null){
                server.close();
                System.out.println("close task successed");
            }
        } catch (IOException e) {
            System.out.println("close task failded");
        }
    }
    @Override
    public void run() {
        try {
            server = new ServerSocket(3333);
        } catch (IOException e) {
            e.printStackTrace();
        }
    } 
    public static void main(String[] args) throws InterruptedException { 
        SocketTask task = new SocketTask();
        task.start();
        Thread.sleep(1000);
        task.stopTask();
    }
}