前几篇都介绍了Thread中的几个方法,相信大家都发现一个相似点,那就是sleep,join,wait这样的阻塞方法都必须捕获一个InterruptedException异常,顾名思义就是一个线程中断的异常,那什么是线程中断呢?线程中断会有哪些问题呢?这一篇我们就来介绍一下线程中断的概念:
在Java的线程Thread类中有三个方法,比较容易混淆,在这里解释一下 (1)interrupt:置线程的中断状态 (2)isInterrupt:线程是否中断 (3)interrupted:返回线程的上次的中断状态,并清除中断状态 举个例子:
[java] view plain copy class MyThread extends Thread { public void run() { try { while(!Thread.currentThread().isInterrupted()) { //如果线程没有被中断就继续运行 //阻塞代码:sleep,wait等 //当其他线程,调用此线程的interrupt()方法时,会给此线程设置一个中断标志 //sleep,wait等方法会检测这个标志位,同时会抛出InterruptedException,并清除线程的中断标志 //因此在异常段调用Thread.currentThread().isInterrupted()返回为false } } catch (InterruptedException e) { //由于阻塞库函数,如:Object.wait,Thread.sleep除了抛出异常外,还会清除线程中断状态,因此可能在这里要保留线程的中断状态 Thread.currentThread().interrupt();//从新设置线程的中断标志 } } public void cancel() { interrupt(); //中断线程 } }
外部调用
[java] view plain copy MyThread thread = new MyThread(); thread.start(); //开启线程 ...... thread.cancel(); //中断线程 System.out.println(thread.isInterrupt)//打印线程中断标志
一般来说,阻塞函数,如:Thread.sleep、Thread.join、Object.wait等在检查到线程的中断状态时,会抛出InterruptedException,同时会清除线程的中断状态 对于InterruptedException的处理,可以有两种情况: (1)外层代码可以处理这个异常,直接抛出这个异常即可 (2)如果不能抛出这个异常,比如在run()方法内,因为在得到这个异常的同时,线程的中断状态已经被清除了,需要保留线程的中断状态,则需要调用Thread.currentThread().interrupt() 另外,Thread.interrupted()在jdk库的源代码中比较常用,因为它既可以得到上一次线程的中断标志值,又可以同时清除线程的中断标志,一举两得,但同时也有坏处,就是这个函数有清除中断状态的副作用,不容易理解。
从上面的分析可以查出,通过中断机制也可以实现线程的终止,但是这种方式也是基于抛出异常的,所以这种方式也是不安全的,同时我们也可以这样理解就是中断机制就是来结束那些阻塞的线程的,因为阻塞线程回去检查中断标志位,又中断就抛异常来结束线程的运行。
通过这一篇貌似可以理解那些调用阻塞线程的方法为什么要抛出中断异常了,同时也理解了线程的中断机制。