本文共 3200 字，大约阅读时间需要 10 分钟。

interrupt方法的引出

interrupt()不能中断在运行中的线程，它只能改变中断状态而已。

public class InterruptionInJava implements Runnable{
        public static void main(String[] args) throws InterruptedException {
           Thread testThread = new Thread(new InterruptionInJava(),"InterruptionInJava");        //start thread        testThread.start();        Thread.sleep(1000);        //interrupt thread        testThread.interrupt();         System.out.println("main end");     }     @Override    public void run() {
           while(true){
               if(Thread.currentThread().isInterrupted()){
                   System.out.println("Yes,I am interruted,but I am still running");             }else{
                   System.out.println("not yet interrupted");            }        }    }}

结果显示，被中断后，仍旧运行，不停打印Yes,I am interruted,but I am still running

既然是只能修改中断状态，那么我们应该针对中断状态做些什么。

public class InterruptionInJava implements Runnable{
       private volatile static boolean on = false;    public static void main(String[] args) throws InterruptedException     {
           Thread testThread = new Thread(new InterruptionInJava(),"InterruptionInJava");        //start thread        testThread.start();        Thread.sleep(1000);        InterruptionInJava.on = true;         System.out.println("main end");     }     @Override    public void run() {
           while(!on){
               if(Thread.currentThread().isInterrupted()){
                   System.out.println("Yes,I am interruted,but I am still running");            }else{
                   System.out.println("not yet interrupted");            }        }    }}

这种开关的方式看起来包治百病，但是当遇到线程阻塞时，就会很无奈了，正如下面代码所示：

public class InterruptionInJava implements Runnable{
       private volatile static boolean on = false;    public static void main(String[] args) throws InterruptedException {
           Thread testThread = new Thread(new InterruptionInJava(),"InterruptionInJava");        //start thread        testThread.start();        Thread.sleep(1000);        InterruptionInJava.on = true;         System.out.println("main end");     }     @Override    public void run() {
           while(!on){
               try {
                   Thread.sleep(Integer.MAX_VALUE);            } catch (InterruptedException e) {
                   System.out.println("caught exception: "+e);            }        }    }}

线程被阻塞无法被中断。这时候救世主interrupt函数又回来了，它可以迅速中断被阻塞的线程，抛出一个InterruptedException，把线程从阻塞状态中解救出来,show the code。

public class InterruptionInJava implements Runnable{
       private volatile static boolean on = false;    public static void main(String[] args) throws InterruptedException {
           Thread testThread = new Thread(new InterruptionInJava(),"InterruptionInJava");        //start thread        testThread.start();        Thread.sleep(1000);        InterruptionInJava.on = true;        testThread.interrupt();         System.out.println("main end");     }     @Override    public void run() {
           while(!on){
               try {
                   Thread.sleep(10000000);            } catch (InterruptedException e) {
                   System.out.println("caught exception right now: "+e);            }        }    }}

转载地址：https://blog.csdn.net/weixin_38367817/article/details/103812524 如侵犯您的版权，请留言回复原文章的地址，我们会给您删除此文章，给您带来不便请您谅解！