1. 程式人生 > >一文搞懂 Java 執行緒中斷

一文搞懂 Java 執行緒中斷

在之前的一文《如何"優雅"地終止一個執行緒》中詳細說明了 stop 終止執行緒的壞處及如何優雅地終止執行緒,那麼還有別的可以終止執行緒的方法嗎?答案是肯定的,它就是我們今天要分享的——執行緒中斷。

下面的這斷程式碼大家應該再熟悉不過了,執行緒休眠需要捕獲或者丟擲執行緒中斷異常,也就是你在睡覺的時候突然有個人衝進來把你吵醒了。

try {
	Thread.sleep(3000);
} catch (InterruptedException e) {
	e.printStackTrace();
}

此時執行緒被打斷後,程式碼會繼續執行或者丟擲異常結束執行,這並不是我們需要的中斷執行緒的作用。

到底是什麼是執行緒中斷?

執行緒中斷即執行緒執行過程中被其他執行緒給打斷了,它與 stop 最大的區別是:stop 是由系統強制終止執行緒,而執行緒中斷則是給目標執行緒傳送一箇中斷訊號,如果目標執行緒沒有接收執行緒中斷的訊號並結束執行緒,執行緒則不會終止,具體是否退出或者執行其他邏輯由目標執行緒決定。

我們來看下執行緒中斷最重要的 3 個方法,它們都是來自 Thread 類!

1、java.lang.Thread#interrupt

中斷目標執行緒,給目標執行緒發一箇中斷訊號,執行緒被打上中斷標記。

2、java.lang.Thread#isInterrupted()

判斷目標執行緒是否被中斷,不會清除中斷標記。

3、java.lang.Thread#interrupted

判斷目標執行緒是否被中斷,會清除中斷標記。

執行緒中斷實戰

我們來例項演示下執行緒中斷如何用!

示例1(中斷失敗)

/**
 * 微信公眾號:Java技術棧
 */
private static void test1() {
	Thread thread = new Thread(() -> {
		while (true) {
			Thread.yield();
		}
	});
	thread.start();
	thread.interrupt();
}

請問示例1中的執行緒會被中斷嗎?答案:不會,因為雖然給執行緒發出了中斷訊號,但程式中並沒有響應中斷訊號的邏輯,所以程式不會有任何反應。

示例2:(中斷成功)

/**
 * 微信公眾號:Java技術棧
 */
private static void test2() {
	Thread thread = new Thread(() -> {
		while (true) {
			Thread.yield();

			// 響應中斷
			if (Thread.currentThread().isInterrupted()) {
				System.out.println("Java技術棧執行緒被中斷,程式退出。");
				return;
			}
		}
	});
	thread.start();
	thread.interrupt();
}

我們給示例2加上了響應中斷的邏輯,程式接收到中斷訊號打印出資訊後返回退出。

示例3(中斷失敗)

/**
 * 微信公眾號:Java技術棧
 */
private static void test3() throws InterruptedException {
	Thread thread = new Thread(() -> {
		while (true) {
			// 響應中斷
			if (Thread.currentThread().isInterrupted()) {
				System.out.println("Java技術棧執行緒被中斷,程式退出。");
				return;
			}

			try {
				Thread.sleep(3000);
			} catch (InterruptedException e) {
				System.out.println("Java技術棧執行緒休眠被中斷,程式退出。");
			}
		}
	});
	thread.start();
	Thread.sleep(2000);
	thread.interrupt();
}

示例3 sleep() 方法被中斷,並輸出了 Java技術棧執行緒休眠被中斷,程式退出。 程式繼續執行……為什麼呢?

來看 sleep 的原始碼:

可以看出 sleep() 方法被中斷後會清除中斷標記,所以迴圈會繼續執行。。

示例4(中斷成功)

/**
 * 微信公眾號:Java技術棧
 */
private static void test4() throws InterruptedException {
	Thread thread = new Thread(() -> {
		while (true) {
			// 響應中斷
			if (Thread.currentThread().isInterrupted()) {
				System.out.println("Java技術棧執行緒被中斷,程式退出。");
				return;
			}

			try {
				Thread.sleep(3000);
			} catch (InterruptedException e) {
				System.out.println("Java技術棧執行緒休眠被中斷,程式退出。");
				Thread.currentThread().interrupt();
			}
		}
	});
	thread.start();
	Thread.sleep(2000);
	thread.interrupt();
}

示例4全部資訊輸出並正常退出,只是在 sleep() 方法被中斷並清除標記後手動重新中斷當前執行緒,然後程式接收中斷訊號返回退出。

通過以上 4 箇中斷示例,相信對 Java 執行緒中斷的概念有了全面的瞭解。更多 Java 多執行緒技術文章請在後臺回覆關鍵字:多執行緒。

更多幹貨推薦

更多請掃描下方的二維碼關注我們的微信公眾號,乾貨每日推送!

Java技術棧