文章目錄

• 概述 stop() Deprecated
• 方式一 設(shè)置開關(guān)
• 方式二 調(diào)用interrupt API
• 方式三 暴力結(jié)束線程-> Daemon Thread + interrupt API

---

概述 stop() Deprecated

通過閱讀源碼或者官方的API，可以知道 Thread#stop() 方法已經(jīng)被廢棄了。

大致意思

這種方法本質(zhì)上是不安全的。

使用Thread.stop停止線程會(huì)導(dǎo)致它解鎖所有已鎖定的監(jiān)視
如果先前由這些監(jiān)視器保護(hù)的任何對象處于不一致狀態(tài)，則損壞的對象將對其他線程可見，從而可能導(dǎo)致任意行為。

stop的許多用法應(yīng)由僅修改某些變量以指示目標(biāo)線程應(yīng)停止運(yùn)行的代碼代替。
目標(biāo)線程應(yīng)定期檢查此變量，如果該變量指示要停止運(yùn)行，則應(yīng)按有序方式從其運(yùn)行方法返回。

如果目標(biāo)線程等待很長時(shí)間（例如，在條件變量上），則應(yīng)使用中斷方法來中斷等待

詳見： —> Why are Thread.stop, Thread.suspend and Thread.resume Deprecated?.

那該如何正確的終止線程呢？ 這里給出幾個(gè)思路及demo,供大家參考

---

方式一 設(shè)置開關(guān)

package com.artisan.test;public class StopThread_1 {public static void main(String[] args) {WorkThread workThread = new WorkThread();workThread.start();// main線程繼續(xù)執(zhí)行業(yè)務(wù)邏輯 假設(shè)運(yùn)行了3秒try {System.out.println(Thread.currentThread().getName() + " 運(yùn)行中");Thread.sleep(3_000);// 假設(shè)觸發(fā)某個(gè)條件，需要退出WorkThread線程workThread.shutdownThread();} catch (InterruptedException e) {e.printStackTrace();}}static class WorkThread extends Thread {// 線程內(nèi)部設(shè)置開關(guān) volatile 多線程可見private volatile boolean flag = true;@Overridepublic void run() {System.out.println(Thread.currentThread().getName() + " working , flag=" + flag);// 通過接收flag來決定 終止或運(yùn)行while (flag) {// do something ......}}private void shutdownThread() {this.flag = false;System.out.println(Thread.currentThread().getName() + " set flag=" + flag);}}}

運(yùn)行結(jié)果：

---

方式二 調(diào)用interrupt API

package com.artisan.test;public class StopThread_2 {public static void main(String[] args) {WorkThread workThread = new WorkThread("workThread");workThread.start();try {// 模擬主線程的業(yè)務(wù)System.out.println(Thread.currentThread().getName() + " working...");Thread.sleep(3_000);// 假設(shè)觸發(fā)了某種條件，需要中斷workThread線程的執(zhí)行 調(diào)用interruptworkThread.interrupt();System.out.println("workThread interrupt...");} catch (InterruptedException e) {e.printStackTrace();}}static class WorkThread extends Thread {public WorkThread(String name) {super(name);}@Overridepublic void run() {System.out.println(Thread.currentThread().getName() + " working ");// 死循環(huán)while (true) {// 判斷 該線程是否被打斷if (Thread.interrupted()) {System.out.println(Thread.currentThread().getName() + " received interrupt signal...");// break (break的話 還會(huì)執(zhí)行 assume some logic is here的代碼)// 或者// return (return 的話，如果有后面還有代碼的話就不會(huì)執(zhí)行后續(xù)的代碼了)break;}// assume some logic is here}}}}

運(yùn)行結(jié)果：

---

方式三 暴力結(jié)束線程-> Daemon Thread + interrupt API

我們在前面使用了

高并發(fā)編程-Daemon Thread的創(chuàng)建以及使用場景分析

高并發(fā)編程-Thread#interrupt用法及源碼分析

在Daemon Thread中我們知道： UserThread 結(jié)束后, 那在UserThread中設(shè)置的Daemon Thread ,JVM不關(guān)心守護(hù)程序線程是否正在運(yùn)行，也就是說即使是Daemon Thread 還在運(yùn)行，只要UserThread結(jié)束了，那么Daemon Thread 就一定會(huì)退出，這是由JVM保障的。

那提個(gè)問題：

1：那我們是不是可以把業(yè)務(wù)線程設(shè)置成Daemon Thread 呢？

2： 假設(shè)可以的話，那哪個(gè)線程要和Daemon Thread 綁定在一起呢？

3： 和Daemon Thread 綁定在一起該如何結(jié)束呢？

針對問題1 —> 可以

針對問題2 —>實(shí)例化一個(gè)用于創(chuàng)建UserThread的類，用于創(chuàng)建UserThread執(zhí)行線程. 在這個(gè)UserThread執(zhí)行線程中，實(shí)例化一個(gè)線程出來，并設(shè)置該線程為Daemon Thread,用于執(zhí)行業(yè)務(wù)邏輯

針對問題3 —> 這里我們可以借用interrupt的方式來終止和Daemon Thread 綁定在一起的User Thread.

package com.artisan.test;public class ThreadControl {//執(zhí)行線程private Thread executeThread;// 內(nèi)存可見的標(biāo)識(shí)符號private volatile boolean finished = false;public void execute(Runnable task) {// Step1 創(chuàng)建執(zhí)行線程 并啟動(dòng)executeThread = new Thread(() -> {// Step2 創(chuàng)建守護(hù)線程 用于執(zhí)行任務(wù)Thread runner = new Thread(task);runner.setDaemon(true);// 啟動(dòng)守護(hù)線程執(zhí)行任務(wù)（當(dāng)外層的執(zhí)行線程結(jié)束的時(shí)候，JVM會(huì)確保將該守護(hù)線程也一并關(guān)閉）runner.start();try {// join到當(dāng)前線程，該任務(wù)完成后，才繼續(xù)后續(xù)的代碼，如果未執(zhí)行完會(huì)一直阻塞在這里runner.join();// runner執(zhí)行完以后，設(shè)置finished為truefinished = true;} catch (InterruptedException e) {//e.printStackTrace();}});// 啟動(dòng)執(zhí)行線程executeThread.start();System.out.println("任務(wù)開始執(zhí)行...");}/*** 該shutdown方法，由創(chuàng)建ThreadControl實(shí)例的線程調(diào)用* @param mills 最大執(zhí)行時(shí)間*/public void shutdown(long mills) {long shutdownTime = System.currentTimeMillis();// 如果任務(wù)沒有執(zhí)行完...while (!finished) {//任務(wù)超時(shí)。即在規(guī)定的最大執(zhí)行時(shí)間內(nèi)未完成,終止該任務(wù)if (System.currentTimeMillis() - shutdownTime >= mills){// 調(diào)用interrupt方法 ,退出當(dāng)前執(zhí)行線程executeThread.interrupt();System.out.println("任務(wù)超時(shí)，interrupt該任務(wù)！");break;}// 如果沒有超時(shí)，休眠1毫秒 ,然后再繼續(xù)進(jìn)到while循環(huán)判斷try {Thread.sleep(1);} catch (InterruptedException e) {System.out.println("執(zhí)行線程被打斷");break;}}// 恢復(fù)初始狀態(tài)finished = false;}public static void main(String[] args) {// 測試一 ： 任務(wù)在規(guī)定的最大存活時(shí)間內(nèi)未執(zhí)行完成long start = System.currentTimeMillis();ThreadControl ts = new ThreadControl();ts.execute(() -> {while (true) {//假設(shè)死循環(huán)，一直運(yùn)行}});// 最長執(zhí)行10秒，超過10秒，中斷該線程ts.shutdown(10_000);long end = System.currentTimeMillis();System.out.printf("任務(wù)被終止，共耗時(shí)【%s】", end - start);System.out.println("=====================================");// 測試二 ： 任務(wù)執(zhí)行時(shí)間小于規(guī)定的最大存活時(shí)間start = System.currentTimeMillis();ThreadControl tc = new ThreadControl();// 模擬該任務(wù) 5秒執(zhí)行完成tc.execute(() -> {try {Thread.sleep(5_000);} catch (InterruptedException e) {e.printStackTrace();}});// 最大允許存活10秒tc.shutdown(10_000);end = System.currentTimeMillis();System.out.printf("任務(wù)已結(jié)束，共耗時(shí)【%s】", end - start);}}

執(zhí)行結(jié)果：

總結(jié)

以上是生活随笔為你收集整理的高并发编程-Thread_正确关闭线程的三种方式的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。