文章目錄

• 概述 stop() Deprecated
• 方式一 設置開關
• 方式二 調用interrupt API
• 方式三 暴力結束線程-> Daemon Thread + interrupt API

---

概述 stop() Deprecated

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

大致意思

這種方法本質上是不安全的。

使用Thread.stop停止線程會導致它解鎖所有已鎖定的監視
如果先前由這些監視器保護的任何對象處于不一致狀態，則損壞的對象將對其他線程可見，從而可能導致任意行為。

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

如果目標線程等待很長時間（例如，在條件變量上），則應使用中斷方法來中斷等待

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

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

---

方式一 設置開關

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

運行結果：

---

方式二 調用interrupt API

package com.artisan.test;public class StopThread_2 {public static void main(String[] args) {WorkThread workThread = new WorkThread("workThread");workThread.start();try {// 模擬主線程的業務System.out.println(Thread.currentThread().getName() + " working...");Thread.sleep(3_000);// 假設觸發了某種條件，需要中斷workThread線程的執行 調用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 ");// 死循環while (true) {// 判斷 該線程是否被打斷if (Thread.interrupted()) {System.out.println(Thread.currentThread().getName() + " received interrupt signal...");// break (break的話 還會執行 assume some logic is here的代碼)// 或者// return (return 的話，如果有后面還有代碼的話就不會執行后續的代碼了)break;}// assume some logic is here}}}}

運行結果：

---

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

我們在前面使用了

高并發編程-Daemon Thread的創建以及使用場景分析

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

在Daemon Thread中我們知道： UserThread 結束后, 那在UserThread中設置的Daemon Thread ,JVM不關心守護程序線程是否正在運行，也就是說即使是Daemon Thread 還在運行，只要UserThread結束了，那么Daemon Thread 就一定會退出，這是由JVM保障的。

那提個問題：

1：那我們是不是可以把業務線程設置成Daemon Thread 呢？

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

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

針對問題1 —> 可以

針對問題2 —>實例化一個用于創建UserThread的類，用于創建UserThread執行線程. 在這個UserThread執行線程中，實例化一個線程出來，并設置該線程為Daemon Thread,用于執行業務邏輯

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

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

執行結果：

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。