設想這樣的情景:我們的應用在某一個時間段內,需要一個子線程不停的在后臺運行,這可能是一個下載過程,是一個對服務端socket的監聽,也可能是一個繪圖的計算過程。當我們想要終止線程的時候,我們會怎樣做呢?是設定一個標志變量來控制跳出循環?還是使用thread.stop()?又或者是設置thread = null?
托福答案 有的時候我們需要一種規范的思路,使用規范的方法來解決一類問題。
我們首先要明白,線程終止的條件,有三種情況:
1.當線程的run方法執行方法體中最后一條語句后。
2.當執行retutrn語句返回時。
3.當出現了在方法中沒有捕獲的異常時。
在Java的早期版本中,還有一個stop方法,其他線程可以調用它終止線程,但是這個方法已經被棄用了,所以還在用的同學就不要繼續用了。
我們的正確思路是,使用interrupt方法來終止我們的線程。
首先要理解interrupt方法做了什么:每一個線程都有一個中斷狀態,這是一個boolean標志,當線程調用了interrupt方法時,這個中斷狀態就會被置位。如果我們要檢查中斷狀態,可以使用Thread.currentThread()。isInterrupted()來獲得是否中斷。
托福答案 但是如果線程被阻塞了(sleep or wait),當我們調用了interrupt方法的時候,就會產生InterruptedException異常。這是我們可以利用的地方。
同樣的,如果中斷狀態先被置位了,然后我們調用了sleep方法,線程不會休眠,相反,它將清除中斷狀態,然后拋出InterruptedException.
我們調用了interrupt并不意味著線程會終止,線程是否會終止,以及會如何繼續,是程序員來控制的。
在本文中我們將會討論終止線程的規范用法,然后在一個例子中實際應用,在這個例子中我們模擬了文件拷貝和游戲繪圖兩種情形。做出的效果如下圖所示,點擊start后上方進度條會顯示文件拷貝的進度,點擊end則會停止拷貝。點擊draw會在畫面中不停繪制各種各樣的矩形,點擊stop則會停止繪制。
托福答案 首先我們來看兩種情形的后臺線程寫法:
public void run() {
try{
…
while(!Thread.currentThread.isInterrupted() && more work to do)
{
do more work
}
}
catch(InterruptedException)
{
//thread was interrupted during sleep or wait
}
finally
{
cleanup, if required
}
//exiting the run method terminates the thread }
public void run() {
try{
…
while( more work to do)
{
do more work
Thread.sleep(delay);
}
}
catch(InterruptedException)
{
//thread was interrupted during sleep or wait
}
finally
{
cleanup, if required
}
//exiting the run method terminates the thread }
第一種寫法適用于后臺下載,文件拷貝以及類似情形,第二種寫法適合游戲畫面刷新或者類似情形。
第一種寫法利用了interrupt方法,作為終止的請求,使得循環跳出,run方法執行完畢。而第二種方法則是利用當線程sleep的時候調用interrupt會拋出InterruptedException從而跳出了循環進而線程執行到結束。
事實上這兩種寫法的區別就在于第二種使用了sleep.
在我們的使用示例中,對應這兩種方法的使用代碼如下:
這一段是實現文件拷貝的:
private class CopyRunnable implements Runnable {
@Override
public void run() {
File fromFile = new File(Environment.getExternalStorageDirectory()
.getAbsolutePath() + "/abc.exe");
long fileLength = fromFile.length();
long copyedLength = 0;
File toFile = new File(Environment.getExternalStorageDirectory()
.getAbsolutePath() + "/abc_.exe");
if (toFile.exists()) {
toFile.delete();
}
try {
FileInputStream fileInputStream = new FileInputStream(fromFile);
FileOutputStream fileOutputStream = new FileOutputStream(
toFile, true);
byte[] buffer = new byte[2048];
int readLength = 0;
while (!Thread.currentThread()。isInterrupted()
&& (readLength = fileInputStream.read(buffer)) != -1) {
fileOutputStream.write(buffer, 0, buffer.length);
copyedLength += readLength;
int progress = (int)
((float) copyedLength / fileLength * 100);
handler.obtainMessage(0, progress, 0)。sendToTarget();
}
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} finally {
handler.obtainMessage(1)。sendToTarget();
}
}
}
這一段是實現矩形繪圖的:
private class DrawRunnable implements Runnable {
@Override
public void run() {
try {
while (true) {
long beginTime = System.currentTimeMillis();
paint.setColor(getColor());
getCoor();
postInvalidate();
long endTime = System.currentTimeMillis();
if (endTime - beginTime < 150) {
Thread.sleep(150 - (endTime - beginTime));
}
}
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
}
}
}
實際上這兩種寫法都是利用了interrupt方法的特點,通過線程的中斷置位或者異常拋出來跳出循環進而終結線程。如果對這段代碼感興趣,可以到文章最后下載代碼。
最后做一下方法總結:
void interrupt()
向線程發送中斷請求。線程的中斷狀態將被設置為true.如果目前該線程被一個sleep調用阻塞,那么,InterruptedException異常被拋出。
static boolean interrupted()
測試當前線程(即正在執行這一命令的線程)是否被中斷,注意,這是一個靜態方法。這一調用會產生副作用,它將當前線程的中斷狀態設置為false.
boolean isInterrupted()
測試線程是否被中斷。不像靜態的中斷方法,這一調用不會改變線程的中斷狀態。
static Thread currentThread()
返回代表當前執行線程的Thread對象。