正確結(jié)束Java線程的方法

更新時間：2019年05月31日 15:07:43 作者：展翅而飛

線程的啟動很簡單，但用戶可能隨時取消任務(wù)，怎么樣讓跑起來的線程正確地結(jié)束，這是今天要討論的話題。下面小編來和大家一起學(xué)習(xí)一下吧

使用標(biāo)志位

很簡單地設(shè)置一個標(biāo)志位，名稱就叫做isCancelled。啟動線程后，定期檢查這個標(biāo)志位。如果isCancelled=true，那么線程就馬上結(jié)束。

public class MyThread implements Runnable{
private volatile boolean isCancelled;
public void run(){
while(!isCancelled){
//do something
}
}
public void cancel(){ isCancelled=true; }
}

注意的是，isCancelled需要為volatile，保證線程讀取時isCancelled是最新數(shù)據(jù)。
我以前經(jīng)常用這種簡單方法，在大多時候也很有效，但并不完善。考慮下，如果線程執(zhí)行的方法被阻塞，那么如何執(zhí)行isCancelled的檢查呢？線程有可能永遠(yuǎn)不會去檢查標(biāo)志位，也就卡住了。

使用中斷

Java提供了中斷機(jī)制，Thread類下有三個重要方法。

public void interrupt()
public boolean isInterrupted()
public static boolean interrupted(); // 清除中斷標(biāo)志，并返回原狀態(tài)

每個線程都有個boolean類型的中斷狀態(tài)。當(dāng)使用Thread的interrupt()方法時，線程的中斷狀態(tài)會被設(shè)置為true。
下面的例子啟動了一個線程，循環(huán)執(zhí)行打印一些信息。使用isInterrupted()方法判斷線程是否被中斷，如果是就結(jié)束線程。

public class InterruptedExample {
public static void main(String[] args) throws Exception {
InterruptedExample interruptedExample = new InterruptedExample();
interruptedExample.start();
}
public void start() {
MyThread myThread = new MyThread();
myThread.start();
try {
Thread.sleep(3000);
myThread.cancel();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
private class MyThread extends Thread{
@Override
public void run() {
while (!Thread.currentThread().isInterrupted()) {
try {
System.out.println("test");
Thread.sleep(1000);
} catch (InterruptedException e) {
System.out.println("interrupt");
//拋出InterruptedException后中斷標(biāo)志被清除，標(biāo)準(zhǔn)做法是再次調(diào)用interrupt恢復(fù)中斷
Thread.currentThread().interrupt();
}
}
System.out.println("stop");
}
public void cancel(){
interrupt();
}
}
}

對線程調(diào)用interrupt()方法，不會真正中斷正在運(yùn)行的線程，只是發(fā)出一個請求，由線程在合適時候結(jié)束自己。

例如Thread.sleep這個阻塞方法，接收到中斷請求，會拋出InterruptedException，讓上層代碼處理。這個時候，你可以什么都不做，但等于吞掉了中斷。因?yàn)閽伋鯥nterruptedException后，中斷標(biāo)記會被重新設(shè)置為false！看sleep()的注釋，也強(qiáng)調(diào)了這點(diǎn)。

@throws InterruptedException
if any thread has interrupted the current thread. 
The interrupted status of the current thread is 
cleared when this exception is thrown.
public static native void sleep(long millis) throws InterruptedException;

記得這個規(guī)則：什么時候都不應(yīng)該吞掉中斷！每個線程都應(yīng)該有合適的方法響應(yīng)中斷！

所以在InterruptedExample例子里，在接收到中斷請求時，標(biāo)準(zhǔn)做法是執(zhí)行Thread.currentThread().interrupt()恢復(fù)中斷，讓線程退出。

從另一方面談起，你不能吞掉中斷，也不能中斷你不熟悉的線程。如果線程沒有響應(yīng)中斷的方法，你無論調(diào)用多少次interrupt()方法，也像泥牛入海。

用Java庫的方法比自己寫的要好

自己手動調(diào)用interrupt()方法來中斷程序，OK。但是Java庫提供了一些類來實(shí)現(xiàn)中斷，更好更強(qiáng)大。

Executor框架提供了Java線程池的能力，ExecutorService擴(kuò)展了Executor，提供了管理線程生命周期的關(guān)鍵能力。其中，ExecutorService.submit返回了Future對象來描述一個線程任務(wù)，它有一個cancel()方法。

下面的例子擴(kuò)展了上面的InterruptedExample，要求線程在限定時間內(nèi)得到結(jié)果，否則觸發(fā)超時停止。

public class InterruptByFuture {
public static void main(String[] args) throws Exception {
ExecutorService es = Executors.newSingleThreadExecutor();
Future<?> task = es.submit(new MyThread());
try {
//限定時間獲取結(jié)果
task.get(5, TimeUnit.SECONDS);
} catch (TimeoutException e) {
//超時觸發(fā)線程中止
System.out.println("thread over time");
} catch (ExecutionException e) {
throw e;
} finally {
boolean mayInterruptIfRunning = true;
task.cancel(mayInterruptIfRunning);
}
}
private static class MyThread extends Thread {
@Override
public void run() {
while (!Thread.currentThread().isInterrupted()) { 
try {
System.out.println("count");
Thread.sleep(1000);
} catch (InterruptedException e) {
System.out.println("interrupt");
Thread.currentThread().interrupt();
}
}
System.out.println("thread stop");
}
public void cancel() {
interrupt();
}
}
}

Future的get方法可以傳入時間，如果限定時間內(nèi)沒有得到結(jié)果，將會拋出TimeoutException。此時，可以調(diào)用Future的cancel()方法，對任務(wù)所在線程發(fā)出中斷請求。
cancel()有個參數(shù)mayInterruptIfRunning，表示任務(wù)是否能夠接收到中斷。