前言

這里主要探討中斷常用的三個(gè)方法:

• interrupt()。在一個(gè)線程中調(diào)用需要中斷現(xiàn)成的interrupt()方法，會(huì)對(duì)該線程發(fā)出信號(hào)，將中斷狀態(tài)標(biāo)志為true
• isInterrupted()。判斷當(dāng)前線程的中斷狀態(tài)。
• interrupted()。將線程的中斷狀態(tài)恢復(fù)。

主要使用的阻塞三個(gè)方法：

• Object#wait。放棄鎖+等待+重新獲取鎖
• Thread#join?！緟f(xié)作】等待某個(gè)線程執(zhí)行完畢
• Thread#sleep。靜態(tài)方法，線程休眠并讓出CPU時(shí)間片

==注意：interrupt()不能中斷在運(yùn)行中的線程，它只能改變中斷狀態(tài)而已。實(shí)際完成的是讓受阻塞的線程退出阻塞狀態(tài)。==
確切的說(shuō)：是被三種方法之一阻塞時(shí)，調(diào)用該線程的interrupt()方法，那么線程將拋出一個(gè)個(gè)InterruptedException中斷異常，從而提早地終結(jié)被阻塞狀態(tài)。

示例說(shuō)明

public class Runner3 implements Runnable {
? ? @Override
? ? public void run() {
? ? ? ? while (true) {
? ? ? ? ? ? if (Thread.currentThread().isInterrupted()) {
? ? ? ? ? ? ? ? System.out.println("我進(jìn)入中斷了，但我還在跑");
? ? ? ? ? ? } else {
? ? ? ? ? ? ? ? System.out.println("我沒有進(jìn)入中斷");
? ? ? ? ? ? }
? ? ? ? }
? ? }
? ??
? ? public static void main(String[] args) {

? ? ? ? Runner3 runner3 = new Runner3();
? ? ? ? Thread thread3 = new Thread(runner3);
? ? ? ? thread3.start();

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

? ? ? ? thread3.interrupt();
? ? }
}

輸出結(jié)果大致如下：

我沒有進(jìn)入中斷
我沒有進(jìn)入中斷
我進(jìn)入中斷了，但我還在跑
我進(jìn)入中斷了，但我還在跑
我進(jìn)入中斷了，但我還在跑
...

這里看到，執(zhí)行interrupt()后，對(duì)線程執(zhí)行中斷后依然在執(zhí)行，線程依然在運(yùn)行。

我們調(diào)整一下run方法

   public void run() {
        while (true) {
            if (Thread.currentThread().isInterrupted()) {
                System.out.println("我進(jìn)入中斷了，但我還在跑");
                Thread.interrupted();//重置狀態(tài)
            } else {
                System.out.println("我沒有進(jìn)入中斷");
            }
        }
    }

輸出結(jié)果如下：

我沒有進(jìn)入中斷
我沒有進(jìn)入中斷
我進(jìn)入中斷了，但我還在跑
我沒有進(jìn)入中斷
我沒有進(jìn)入中斷
...

這里看到中斷的狀態(tài)重置了，那么我們?nèi)绾稳?yīng)用這個(gè)中斷狀態(tài)呢？

注意事項(xiàng)

• 當(dāng)線程A執(zhí)行到wait(),sleep(),join()時(shí),拋出InterruptedException后，中斷狀態(tài)已經(jīng)被系統(tǒng)復(fù)位了，線程A調(diào)用Thread.interrupted()返回的是false。
• 如果線程被調(diào)用了interrupt()，此時(shí)該線程并不在阻塞狀態(tài)時(shí)，下次執(zhí)行wait(),sleep(),join()時(shí)，一樣會(huì)拋出InterruptedException，當(dāng)然拋出后該線程的中斷狀態(tài)也會(huì)被系統(tǒng)復(fù)位。

案例1

public class Runner3 implements Runnable {
? ? @Override
? ? public void run() {
? ? ? ? while (true) {
? ? ? ? ? ? if (Thread.currentThread().isInterrupted()) {
? ? ? ? ? ? ? ? System.out.println("我進(jìn)入中斷了，但我還在跑");
// ? ? ? ? ? ? ??
? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? Thread.sleep(5000);
? ? ? ? ? ? ? ? } catch (InterruptedException e) {
? ? ? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? ? ? ? ? System.out.println("2"+Thread.currentThread().isInterrupted());
? ? ? ? ? ? ? ? ? ? //輸出false
? ? ? ? ? ? ? ? }
? ? ? ? ? ? } else {
? ? ? ? ? ? ? ? System.out.println("我沒有進(jìn)入中斷");
? ? ? ? ? ? }
? ? ? ? ? ??
? ? ? ? }
? ? }

? ? public static void main(String[] args) {
? ? ? ? Runner3 runner3 = new Runner3();
? ? ? ? Thread thread3 = new Thread(runner3);
? ? ? ? thread3.start();
? ? ? ? try {
? ? ? ? ? ? Thread.sleep(2000);
? ? ? ? } catch (InterruptedException e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? }
? ? ? ? thread3.interrupt();
? ? }
}

執(zhí)行上面的代碼，我們可以看到在拋出異常后，Thread.currentThread().isInterrupted()輸出為false，證明線程的中斷狀態(tài)已經(jīng)復(fù)位了。
另外因?yàn)槲覀兪窍葓?zhí)行了interrupt()然后再進(jìn)入睡眠狀態(tài)，但是依然拋出了異常。

Object#wait 和 Thread.sleep 差異在哪里

因?yàn)镺bject#wait方法會(huì)阻塞線程，所以當(dāng)我們執(zhí)行interrupt時(shí)，會(huì)拋出InterruptedException異常。
那么Object#wait方法阻塞線程會(huì)導(dǎo)致的差異在哪里？
==最主要的差別在于sleep方法沒有釋放鎖，而wait方法釋放了鎖，使得其它線程可以使用同步控制塊或者方法。==

總結(jié)

• 調(diào)用interrupt方法，會(huì)改變中斷狀態(tài)，但不會(huì)影響線程的運(yùn)行狀態(tài)。
• 當(dāng)執(zhí)行了interrupt方法改變中斷狀態(tài)后，線程若執(zhí)行Object#wait，Thread#sleep和Thread#join都會(huì)拋出InterruptedException異常，然后復(fù)位中斷狀態(tài)
• 當(dāng)執(zhí)行了interrupt方法改變中斷狀態(tài)后，線程未阻塞，且將要執(zhí)行Object#wait，Thread#sleep和Thread#join阻塞線程時(shí)，都會(huì)拋出InterruptedException異常，復(fù)位中斷狀態(tài)。

到此這篇關(guān)于Java線程中斷interrupt的常用方法的文章就介紹到這了,更多相關(guān)Java線程中斷interrupt內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論