Java 線程中斷(interrupt)與阻塞 (park)的區(qū)別

王偉廷發(fā)布于2019-08-19 11:10 / 2906人閱讀

摘要：很多開發(fā)人員包括我，尤其是剛進(jìn)入軟件行業(yè)的新手，認(rèn)為設(shè)置線程中斷就是表示線程停止了，不往前執(zhí)行了，其實不是這樣的，線程中斷只是一個狀態(tài)而已，表示已中斷，表示未中斷獲取線程中斷狀態(tài)，如果中斷了返回否則返回設(shè)置線程中斷不影響線程的繼續(xù)執(zhí)行，但是

? ? 很多Java開發(fā)人員(包括我)，尤其是剛進(jìn)入軟件行業(yè)的新手，認(rèn)為Java設(shè)置線程中斷就是表示線程停止了，不往前執(zhí)行了，

Thread.currentThread().interrupt()

? ?其實不是這樣的，線程中斷只是一個狀態(tài)而已，true表示已中斷，false表示未中斷

//獲取線程中斷狀態(tài)，如果中斷了返回true,否則返回false
Thread.currentThread().isInterrupted()
? 設(shè)置線程中斷不影響線程的繼續(xù)執(zhí)行，但是線程設(shè)置中斷后，線程內(nèi)調(diào)用了wait、jion、sleep方法中的一種，立馬拋出一個 InterruptedException，且中斷標(biāo)志被清除，重新設(shè)置為false。

class Thread2 implements Runnable{

    @Override
    public void run() {
        try {
            System.out.println();
            System.out.println(hread.currentThread().isInterrupted());//輸出false
            Thread.currentThread().interrupt();//當(dāng)前線程中斷
            System.out.println("Thread.currentThread().isInterrupted());//輸出true
            Thread.sleep(3000);//中斷后執(zhí)行sleep會拋出異常
        } catch (InterruptedException e) {
            e.printStackTrace();
            System.out.println("Thread.currentThread().isInterrupted());//輸出false
        }
       
    }
}

該如何讓線程真正停止不往前執(zhí)行呢:
?真正讓線程停止下來(阻塞)，Java提供了一個較為底層的并發(fā)工具類:LockSupport，該類常用的方法有兩個,1?

park(Object blocker) 表示阻塞指定線程，參數(shù)blocker當(dāng)前線程對象 2 unpark(Thread thread) 喚醒指定線程，參數(shù)thread指定線程對象
示例:

 public void test_LockSupport(){
      Thread thread=new Thread(new Thread_park());
      thread.start();//阻塞當(dāng)前線程
      Thread thread2=new Thread(new Thread_unpark(thread));
      thread2.start();//喚醒被阻塞的線程
  }

  class Thread_park implements  Runnable{
    @Override
    public void run() {
        System.out.println("Thread_park開始");
        LockSupport.park(this);//阻塞當(dāng)前線程
        System.out.println("Thread_park結(jié)束");
     }
  }

 class Thread_unpark implements  Runnable{
    private Thread thread;

    public Thread_unpark(Thread thread) {
        this.thread = thread;
    }

    @Override
    public void run() {
        System.out.println("Thread_unpark開始");
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        LockSupport.unpark(thread);//喚醒被阻塞的線程
        System.out.println("Thread_unpark結(jié)束");
    }
}