关于高并发:InterruptedException异常会对并发编程产生哪些影响

写在后面

InterruptedException 异样可能没你想的那么简略！

前言

当咱们在调用 Java 对象的 wait()办法或者线程的 sleep()办法时，须要捕捉并解决 InterruptedException 异样。如果咱们对 InterruptedException 异样处理不当，则会产生咱们意想不到的结果！

程序案例

例如，上面的程序代码，InterruptedTask 类实现了 Runnable 接口，在 run()办法中，获取以后线程的句柄，并在 while(true)循环中，通过 isInterrupted()办法来检测以后线程是否被中断，如果以后线程被中断就退出 while(true)循环，同时，在 while(true)循环中，还有一行 Thread.sleep(100)代码，并捕捉了 InterruptedException 异样。整个代码如下所示。

package io.binghe.concurrent.lab08;

/**
 * @author binghe
 * @version 1.0.0
 * @description 线程测试中断
 */
public class InterruptedTask implements Runnable{

    @Override
    public void run() {Thread currentThread = Thread.currentThread();
        while (true){if(currentThread.isInterrupted()){break;}

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

上述代码的本意是通过 isInterrupted()办法查看线程是否被中断了，如果中断了就退出 while 循环。其余线程通过调用执行线程的 interrupt()办法来中断执行线程，此时会设置执行线程的中断标记位，从而使 currentThread.isInterrupted()返回 true，这样就可能退出 while 循环。

这看上去没啥问题啊！但真的是这样吗？咱们创立一个 InterruptedTest 类用于测试，代码如下所示。

package io.binghe.concurrent.lab08;

/**
 * @author binghe
 * @version 1.0.0
 * @description 测试线程中断
 */
public class InterruptedTest {public static void main(String[] args){InterruptedTask interruptedTask = new InterruptedTask();
        Thread interruptedThread = new Thread(interruptedTask);
        interruptedThread.start();
        try {Thread.sleep(1000);
        } catch (InterruptedException e) {e.printStackTrace();
        }
        interruptedThread.interrupt();}
}

咱们运行 main 办法，如下所示。

这居然跟咱们设想的不一样！不一样！不一样！这是为什么呢？

问题剖析

上述代码明明调用了线程的 interrupt()办法来中断线程，然而却并没有起到啥作用。起因是线程的 run()办法在执行的时候，大部分工夫都是阻塞在 sleep(100)上，当其余线程通过调用执行线程的 interrupt()办法来中断执行线程时，大概率的会触发 InterruptedException 异样，在触发 InterruptedException 异样的同时，JVM 会同时把线程的中断标记位革除，所以，这个时候在 run()办法中判断的 currentThread.isInterrupted()会返回 false，也就不会退出以后 while 循环了。

既然问题剖析革除了，那如何中断线程并退出程序呢？

问题解决

正确的解决形式应该是在 InterruptedTask 类中的 run()办法中的 while(true)循环中捕捉异样之后从新设置中断标记位，所以，正确的 InterruptedTask 类的代码如下所示。

package io.binghe.concurrent.lab08;

/**
 * @author binghe
 * @version 1.0.0
 * @description 中断线程测试
 */
public class InterruptedTask implements Runnable{

    @Override
    public void run() {Thread currentThread = Thread.currentThread();
        while (true){if(currentThread.isInterrupted()){break;}

            try {Thread.sleep(100);
            } catch (InterruptedException e) {e.printStackTrace();
                currentThread.interrupt();}
        }
    }
}

能够看到，咱们在捕捉 InterruptedException 异样的 catch 代码块中新增了一行代码。

currentThread.interrupt();

这就使得咱们 捕捉到 InterruptedException 异样后，可能从新设置线程的中断标记位，从而中断以后执行的线程。

咱们再次运行 InterruptedTest 类的 main 办法，如下所示。

总结

解决 InterruptedException 异样时要小心，如果在调用执行线程的 interrupt()办法中断执行线程时，抛出了 InterruptedException 异样，则在触发 InterruptedException 异样的同时，JVM 会同时把执行线程的中断标记位革除，此时调用执行线程的 isInterrupted()办法时，会返回 false。此时，正确的解决形式是在执行线程的 run()办法中捕捉到 InterruptedException 异样，并从新设置中断标记位（也就是在捕捉 InterruptedException 异样的 catch 代码块中，从新调用以后线程的 interrupt()办法）。

写在最初

如果感觉文章对你有点帮忙，请微信搜寻并关注「冰河技术」微信公众号，跟冰河学习高并发编程技术。

最初，附上并发编程须要把握的外围技能常识图，祝大家在学习并发编程时，少走弯路。