停止Thread的方式

當(dāng)你想要依據(jù)某些條件終結(jié)thread的時候,有兩種最常見的方式。

設(shè)定標(biāo)記

最常見停止thread的方式是設(shè)定某些標(biāo)記來表示該thread應(yīng)該要停止了。thread可 以周期性地查詢標(biāo)記以判別它是否應(yīng)該退出。如例:

package test;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;

public class Main {
    public static void main(String[] args) {
        Worker work = new Worker();
        work.start();
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
        try {
            work.setDone(Boolean.parseBoolean(br.readLine()));
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

class Worker extends Thread {
    private volatile boolean done = false;        //注意這里使用了關(guān)鍵詞:volatile
    @Override
    public void run() {
        int i = 0;
        while(!done) {
            System.out.println("number: " + i++);
        }
    }
    /*getter,setter*/
    public boolean isDone() {
        return done;
    }
    public void setDone(boolean done) {
        this.done = done;
    }
}

在這里我們創(chuàng)建了一個boolean的done標(biāo)記以表示thread是否該結(jié)束。現(xiàn)在就不用不停地進行循環(huán)了,run()這個方法會在每次循環(huán)中查看變量并在done標(biāo)記被設(shè)定時返回。這會終結(jié)掉此thread。

中斷Thread

當(dāng)要安排thread終結(jié)的時候出現(xiàn)某種延遲是無可避免的,但有時這樣的延遲必須縮短到最小。在上面的范例中,延遲是在調(diào)用完setDone()方法之后與檢查done變量的值之前執(zhí)行某些語句所造成的。一種比較糟糕的情況是,如果程序中存在sleep()方法的調(diào)用,用來設(shè)置休眠時間(比如:5秒),而setDone()方法調(diào)用剛好發(fā)生在Worker檢查done變量之后。如果恰逢thread休眠,那延遲時間就接近5秒鐘了。

在其它例子中延遲狀況可能還要更糟:如果thread執(zhí)行的是從socket讀取數(shù)據(jù)的read()方法,數(shù)據(jù)可能永遠也不會到來;或者thread可能會執(zhí)行wait()方法來等待一個永遠不會發(fā)生的事件。你這樣的方法都被稱為blocking method,因為它們會阻塞住thread的執(zhí)行直到發(fā)生某事為止(例如說sleep()方法的到期)。

當(dāng)你在安排終結(jié)thread的時候,通常會想立即地完成它的blocking method;因為thread已經(jīng)要結(jié)束了,所以不再需要等待數(shù)據(jù)(或其他什么東西)。此時可以使用Thread類的interrupt()方法來中斷任何的blocking method。

此interrupt()方法有兩個效應(yīng)。首先,它會導(dǎo)致任何的blocked method拋出InterruptedException。例如sleep()方法就是一個blocking method。如果thread在執(zhí)行sleep()方法的時候中斷,此sleep會立刻被喚醒并拋出一個InterruptedException。同樣具有此行為的方法包括:wait(),join()以及讀取I/O的方法。第二個效應(yīng)是設(shè)定thread對象內(nèi)部的標(biāo)記來指示此thread已經(jīng)被中斷,可使用isInterrupted()方法來查詢這個標(biāo)記,此方法會在thread已經(jīng)被中斷時返回true(就算沒有被阻塞?。?/p>

把上面的一個示例修改后,如下:

package test;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;

public class Main1 {
    public static void main(String[] args) {
        Worker2 work = new Worker2();
        work.start();
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
        try {
            if(Boolean.parseBoolean(br.readLine())) {
                work.interrupt();        //中斷線程
                System.out.println("線程是否中斷?" + work.isInterrupted());
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

class Worker2 extends Thread {
    @Override
    public void run() {
        int i = 0;
        while(!isInterrupted()) {        //注意這里isInterrupted()方法的使用
            System.out.println("number: " + i++);
        }
    }
}

這個范例代碼幾乎完全與使用done標(biāo)記的示例代碼相同。在此例中,我們使用中斷標(biāo)記來代替,那就不需要setDone()這個方法了,setDone()方法就用interrupt()方法代替了。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容