快捷導(dǎo)航

Thread類interrupt interrupted及isInterrupted區(qū)別

更新時(shí)間：2022年10月27日 15:20:45 作者：夢(mèng)想實(shí)現(xiàn)家_Z

這篇文章主要為大家介紹了Thread類interrupt interrupted及isInterrupted區(qū)別，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

前言

在java Thread類中，我們會(huì)看到interrupt()、interrupted()及isInterrupted()，在大多數(shù)情況下，我們都不會(huì)使用到它們，但是有一個(gè)InterruptedException類我們應(yīng)該是經(jīng)常會(huì)遇到的，例如：

  public static void main(String[] args) {
    try {
      Thread.sleep(1000);
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
  }

那么你知道InterruptedException異常是如何觸發(fā)的嘛？

如何觸發(fā)InterruptedException

我們發(fā)現(xiàn)，在sleep()、wait()、join()等阻塞方法上才會(huì)需要拋InterruptedException：

  public static void main(String[] args) throws InterruptedException {
    Thread t1 = new Thread(() -> {
      try {
        // 執(zhí)行睡眠1秒，馬上會(huì)被主線程打斷
        Thread.sleep(1000);
      } catch (InterruptedException e) {
        // 觸發(fā)InterruptedException異常
        e.printStackTrace();
        // 打印是否被打斷
        System.out.println(Thread.currentThread().isInterrupted());
      }
    });
    // 主線程啟動(dòng)線程t1
    t1.start();
    // 主線程打斷t1
    t1.interrupt();
    // 等等t1執(zhí)行完畢
    t1.join();
  }

1.我們創(chuàng)建了一個(gè)線程對(duì)象t1，t1執(zhí)行邏輯就是sleep 1秒鐘；不過我們會(huì)發(fā)現(xiàn)線程t1根本sleep不了那么久，因?yàn)橹骶€程馬上就會(huì)打斷它；線程t1被打斷后，會(huì)打印出異常堆棧，并輸出線程t1的打斷標(biāo)記；

2.在主線程中，啟動(dòng)線程t1后，那么就打斷線程t1；

3.等待線程t1邏輯全部執(zhí)行完畢后主線程退出；

我們會(huì)發(fā)現(xiàn)，輸出的線程t1的打斷標(biāo)記一致是false；咱們明明已經(jīng)調(diào)用了t1.interrupt()，并且也觸發(fā)了InterruptedException異常，這到底是為什么導(dǎo)致上面代碼線程t1的打斷標(biāo)記一直是false呢？

我們從JDK源碼中找到了這樣一段注釋：

簡單翻譯如下：如果任何線程打斷當(dāng)前線程，當(dāng)前線程的打斷標(biāo)記在InterruptedException拋出時(shí)會(huì)被清除掉。

所以說，我們?cè)诓蹲降?code>InterruptedException后想要再拿到線程t1的打斷標(biāo)記基本上是不可能的。

interrupt()的作用

在Thread中，我們調(diào)用interrupt()并不會(huì)阻止目標(biāo)線程繼續(xù)執(zhí)行，它只是給目標(biāo)線程打上一個(gè)標(biāo)記：

  public static void main(String[] args) throws InterruptedException {
    // 創(chuàng)建線程t1
    Thread t1 = new Thread(() -> {
      int i = 0;
      // 循環(huán)自增
      while (true) {
        System.out.println(i);
        i++;
        // 判斷是否有打斷標(biāo)記
        if(Thread.currentThread().isInterrupted()){
          System.out.println("線程被打斷，跳出循環(huán)");
          // 如果有打斷標(biāo)記，就跳出循環(huán)
          break;
        }
      }
    });
    // 啟動(dòng)線程t1
    t1.start();
    // 打斷線程t1
    t1.interrupt();
    // 等待線程t1執(zhí)行完畢
    t1.join();
  }

1.在上述代碼中，如果刪掉break代碼，那么線程t1會(huì)一直死循環(huán)，說明interrupt()是無法阻止線程t1執(zhí)行的；

2.在非阻塞代碼中，我們是可以拿到線程t1的打斷標(biāo)記的，也就是說，非阻塞代碼不會(huì)清除線程的打斷標(biāo)記；

interrupted()及isInterrupted()的區(qū)別

我們可以看一下Thread類中這兩個(gè)方法的源代碼：

    // 靜態(tài)方法，調(diào)用當(dāng)前線程的isInterrupted(true)
    public static boolean interrupted() {
        return currentThread().isInterrupted(true);
    }
    // 對(duì)象方法，調(diào)用當(dāng)前線程對(duì)象的isInterrupted(false)
    public boolean isInterrupted() {
        return isInterrupted(false);
    }

根據(jù)上面源碼，我們發(fā)現(xiàn)了interrupted()是一個(gè)靜態(tài)方法，是可以直接通過Thread.interrupted()調(diào)用的；isInterrupted()方法是線程對(duì)象方法，是需要通過線程對(duì)象調(diào)用的；我們?cè)谇懊娲a中使用Thread.currentThread().isInterrupted()就是通過線程對(duì)象調(diào)用的；

另一個(gè)區(qū)別就是兩個(gè)方法傳遞的參數(shù)不同，interrupted()傳遞的true，isInterrupted()傳遞的是false；這兩個(gè)參數(shù)的作用是是否清除打斷標(biāo)記，也就是說，如果調(diào)用Thread.interrupted()返回true后，我們的打斷標(biāo)記會(huì)被清除，那么再次調(diào)用Thread.interrupted()拿到的就是false；isInterrupted()方法就不會(huì)清除打斷標(biāo)記，每次調(diào)用isInterrupted()結(jié)果都不變；