轉(zhuǎn)載大佬地址:http://www.voidcn.com/article/p-uamzdkyd-bwg.html
最近想記錄一下被丧,如何優(yōu)雅的中斷線程任務(wù)的方法竞滓。概括的說欠窒,有3種方法:
1荷腊、通過thread.interrupt,當(dāng)然這需要你線程任務(wù)類里樊销,自己寫"是否中斷"的判斷邏輯
2僵缺、通過Future的cancel方法來實(shí)現(xiàn)踊挠,這也是我們這里要測試的
3弄唧、通過Thead的實(shí)例方法stop來中斷線程啡专,當(dāng)然因?yàn)榇直┖筒话踩呀?jīng)被廢棄 想的很好险毁,也是我想用代碼實(shí)現(xiàn)一下,于是發(fā)現(xiàn)了一個(gè)問題,就是實(shí)用方法2取消線程時(shí)畔况,必須要在任務(wù)類的run方法中使用Thread.sleep()鲸鹦,不然不會被中斷。廢話不說跷跪,上代碼:
package com.nipin.datastructor;
import java.util.Random;
import java.util.concurrent.*;
/**
* Created by nipin on 16/11/28.
* 學(xué)習(xí)如何優(yōu)雅的停止一個(gè)正在執(zhí)行的線程
* 主要思路:
* 1馋嗜、通過thread.interrupt,當(dāng)然這需要你線程任務(wù)類里,自己寫"是否中斷"的判斷邏輯
* 2吵瞻、通過Future的cancel方法來實(shí)現(xiàn)葛菇,這也是我們這里要測試的
* 3、通過Thead的實(shí)例方法stop來中斷線程橡羞,當(dāng)然因?yàn)榇直┖筒话踩呀?jīng)被廢棄
*/
public class ThreadCancelDemo {
public static void main(String[] args) {
//方法1
/*
Thread thread = new Thread(){
@Override
public void run() {
super.run();
while (!isInterrupted()){
try {
Thread.sleep(100l);
System.out.println(Thread.currentThread().getName()+" print random :"+ new Random().nextInt());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
};
thread.start();
Thread.sleep(1000l);
thread.interrupt();
*/
//方法2
ExecutorService executorService = Executors.newFixedThreadPool(10);
Runnable runnable = new Runnable() {
@Override
public void run() {
while (true){
System.out.println(Thread.currentThread().getName()+" print random --> :"+ new Random().nextInt());
}
}
};
try {
Future<?> submit = executorService.submit(runnable);
Thread.sleep(100l);
boolean cancel = submit.cancel(true);
System.out.println("是否已經(jīng)取消"+cancel);
executorService.shutdown();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
只要加上Thread.sleep()眯停,之后,就可以中斷卿泽。不理解其中的道理莺债。 看了Future, future.cancel()可以刪除同步阻塞任務(wù)這個(gè)帖子后,我恍然大悟签夭,我的任務(wù)類里寫了while(true)九府,這樣的線程只有thead.stop能中斷,其他的方式只是改變中斷狀態(tài)標(biāo)志覆致,所以要改為
public void run() {
while (!Thread.currentThread().isInterrupted()){
System.out.println(Thread.currentThread().getName()+" print random --> :"+ new Random().nextInt());
}
這樣就可以中斷了侄旬。