JAVA中斷線程的方法
Thread.stop, Thread.suspend, Thread.resume 和Runtime.runFinalizersOnExit 這些終止線程運(yùn)行的方法已經(jīng)被廢棄,使用它們是極端不安全的!
現(xiàn)在,如果你要安全有效地終止一個(gè)線程,應(yīng)該采用以下這些方法:
1 線程正常執(zhí)行完畢,正常結(jié)束。
也就是讓run方法執(zhí)行完畢,該線程就會(huì)正常結(jié)束。
2 監(jiān)視某些條件,結(jié)束線程的不間斷運(yùn)行。
然而,常常有些線程是伺服線程。它們需要長(zhǎng)時(shí)間的運(yùn)行,只有在外部某些條件滿足的情況下,才能關(guān)閉這些線程。
通常,它們執(zhí)行在一個(gè)while(true)的死循環(huán)中。
如:
publicvoid run() { while(true){ someWork(); if(finished){ break; } try { Thread.sleep(10000); } catch (InterruptedException e) { /* TODO自動(dòng)生成 catch 塊 * */ e.printStackTrace(); } } } |
我們可以在while死循環(huán)內(nèi),每次循環(huán)時(shí),察看外部條件,看看是否需要關(guān)閉當(dāng)前線程。如果是,就break,跳出死循環(huán),或者是拋出異常,跳出死循環(huán),結(jié)束線程。
3 捕獲InterruptedException 運(yùn)行時(shí)異常,中斷當(dāng)前線程。
有些執(zhí)行伺服任務(wù)的線程,在while(true)這樣的死循環(huán)內(nèi)部,是一個(gè)阻塞中的方法。此時(shí),就不能采用第二種方法了。因?yàn)?,?dāng)該方法沒有返回時(shí),該線程一直處于阻塞當(dāng)中,根本無法執(zhí)行其他語句。
此時(shí),就需要調(diào)用該線程的interrupt方法,產(chǎn)生一個(gè)InterruptedException運(yùn)行時(shí)異常,是阻塞中的那個(gè)方法拋出這個(gè)異常,從而讓我們有機(jī)會(huì)結(jié)束這個(gè)線程的執(zhí)行。
如:
publicvoid run() { while(true){ try { // getSendMessages 是BlockingQueue類。它的take方法將會(huì)阻塞! responseMessage = this.getSendMessages().take(); } catch (InterruptedException e1) { thrownew RuntimeException(); //或者break; } someWork(); } |
一個(gè)外部的Thread 對(duì)象 指向這個(gè)線程。 需要結(jié)束這個(gè)線程時(shí),只需要調(diào)用thread對(duì)象的interrupt() 方法,就會(huì)在responseMessage = this.getSendMessages().take();
這條語句中產(chǎn)生一個(gè)InterruptedException異常,從而結(jié)束該線程的阻塞狀態(tài),通過拋出異常,或者break跳出死循環(huán),結(jié)束這個(gè)線程。
【編輯推薦】