Java线程学习笔记(四):线程的中断
方法原型:public void interrupt()
方法说明:
- 中断线程
- 如果当前线程没有中断它自己(这在任何情况下都是允许的),则该线程的checkAccess()方法就会被调用,这可能抛出SecurityException
- 如果线程在调用Object类的wait()、wait(long)或者wait(long, int)方法,或者该类的join()、join(long)、join(long, int)、sleep(long)或者sleep(long, int)方法过程中受阻,则其中断状态将会被清除,它还将抛出一个InterruptedException
- 如果该线程在可中断的通道(InterruptibleChannel)上I/O操作中受阻,则该通道将被关闭,该线程的中断状态将被设置并且该线程将受到一个CloseByInterruptException
- 如果该线程在一个Selector中受阻,则该线程的中断状态将被设置,它将立即从选择操作返回,并可能带有一个非零值,就好像调用了选择器的wakeup方法一样
- 如果以前的条件都没有保存,则该线程的中断状态将被设置
示例1:测试interrupt()方法
public class Hello implements Runnable { private double d = 0.0; public void run() { //死循环执行打印“I am running”和消耗时间的浮点数运算 while (true) { System.out.println("I am running!"); for (int i = 0; i < 900000; i++) { d = d + (Math.PI + Math.E) / d; } //给线程调度器可以调度其它线程的信号 Thread.yield(); } } public static void main(String[] args) throws InterruptedException { Thread t = new Thread(new Hello()); System.out.println("线程的中断状态1:" + t.isInterrupted()); t.start(); t.sleep(100); System.out.println("*****************************"); System.out.println("Interrupted Thread!"); System.out.println("*****************************"); t.interrupt(); System.out.println("线程的中断状态2:" + t.isInterrupted()); } }
I am running!
... ...
I am running!
I am running!
*****************************
Interrupted Thread!
*****************************
线程的中断状态2:true
I am running!
I am running!
... ...
分析:程序虽然调用了interrupt()方法,但是并没有中断执行,而是继续运行。但是interrupt状态由false变为了true。由此得出结论,线程的“中断”不是让线程停止。
Java中线程的中断(interrupt)只是改变了线程的中断状态,这个中断状态改变后带来的结果,是无法确定的。有时,它更是让停止中的线程继续执行的唯一手段,不但不是让线程停止运行的手段,反而是继续执行线程的手段。
离开线程有两种方法:
1、抛出InterruptedException异常
2、用Thread.interrupted()检查是否发生中断
示例2:抛出InterruptedException异常
public class Hello implements Runnable { private double d = 0.0; public void run() { try { //死循环执行打印“I am running”和消耗时间的浮点数运算 while (true) { System.out.println("I am running!"); for (int i = 0; i < 900000; i++) { d = d + (Math.PI + Math.E) / d; } //休眠一段时间,中断后会抛出InterruptedException异常, //当抛出该异常的时候,当前线程的"中断状态"被清除。 Thread.sleep(50); } } catch (InterruptedException e) { e.printStackTrace(); } } public static void main(String[] args) throws InterruptedException { Thread t = new Thread(new Hello()); System.out.println("线程的中断状态1:" + t.isInterrupted()); t.start(); t.sleep(100); System.out.println("*****************************"); System.out.println("Interrupted Thread!"); System.out.println("*****************************"); t.interrupt(); System.out.println("线程的中断状态2:" + t.isInterrupted()); } }
I am running!
I am running!
*****************************
Interrupted Thread!
*****************************
java.lang.InterruptedException: sleep interrupted
at java.lang.Thread.sleep(Native Method)
at com.test2.Hello.run(Hello.java:16)
at java.lang.Thread.run(Thread.java:744)
线程的中断状态2:false
分析:如代码及执行结果所示,子线程run()方法中,每执行一次循环体,就会休眠50ms,当主线程执行到t.interrupt()操作的时候,子线程的中断状态将会改变为true,子线程再执行Thread.sleep()方法的时候,会抛出java.lang.InterruptedException异常,此时子线程的中断状态将会被重置,所以在最后的输出中,子线程的中断状态还是false。
特别注意:run()中的try-catch块,必须将整个while循环括在try块中。如果单独只是括sleep()方法,则线程不会被终止,而是继续执行,原因就是sleep()方法抛出的异常已经被捕获了,而这个被捕获的异常并没有影响到后续程序的运行。
示例3:用Thread.interrupted()检查是否发生中断
public class Hello implements Runnable { private double d = 0.0; public void run() { try { //判断程序是否发生中断 while (!Thread.interrupted()) { System.out.println("I am running!"); for (int i = 0; i < 900000; i++) { d = d + (Math.PI + Math.E) / d; } //休眠一段时间,中断后会抛出InterruptedException异常, //当抛出该异常的时候,当前线程的"中断状态"被清除。 Thread.sleep(50); } } catch (InterruptedException e) { e.printStackTrace(); } } public static void main(String[] args) throws InterruptedException { Thread t = new Thread(new Hello()); System.out.println("线程的中断状态1:" + t.isInterrupted()); t.start(); t.sleep(100); System.out.println("*****************************"); System.out.println("Interrupted Thread!"); System.out.println("*****************************"); t.interrupt(); System.out.println("线程的中断状态2:" + t.isInterrupted()); } }
I am running!
I am running!
*****************************
Interrupted Thread!
*****************************
java.lang.InterruptedException: sleep interrupted
at java.lang.Thread.sleep(Native Method)
at com.test2.Hello.run(Hello.java:17)
at java.lang.Thread.run(Thread.java:744)
线程的中断状态2:false
I am running!
I am running!
*****************************
Interrupted Thread!
*****************************
线程的中断状态2:true
java.lang.InterruptedException: sleep interrupted
at java.lang.Thread.sleep(Native Method)
at com.test2.Hello.run(Hello.java:17)
at java.lang.Thread.run(Thread.java:744)
分析:
- isInterrupted():测试线程是否中断。线程的“中断状态”不受方法的影响。在新版的jre(7)中该结论需要斟酌,个人理解如果没有错的话,isInterrupted()也可能会影响线程的中断状态。
- interrupted():测试当前线程是否已经中断。线程的“中断状态”由该方法清除。换句话说,如果连续两次调用该方法,则第二次调用将返回false(在第一次调用已经清除了其中断状态之后,且第二次调用检查完中断状态前,当前线程再次中断的情况除外)。详见以下补充示例。
- 多执行几次,会出现两个截然不同的结果(最后一次测试中断状态的结果完全相反)。个人理解,由于sleep()方法执行的时间点不同,从而影响了该结果。
补充示例:interrupted()方法验证
public class Hello implements Runnable { private double d = 0.0; public void run() { //判断程序是否发生中断,第一次调用interrupted()方法 while (!Thread.interrupted()) { System.out.println("I am running!"); for (int i = 0; i < 900000; i++) { d = d + (Math.PI + Math.E) / d; } } System.out.println("第二次调用Thread.interrupted()方法:" + Thread.interrupted()); } public static void main(String[] args) throws InterruptedException { Thread t = new Thread(new Hello()); System.out.println("线程的中断状态1:" + t.isInterrupted()); t.start(); t.sleep(100); System.out.println("*****************************"); System.out.println("Interrupted Thread!"); System.out.println("*****************************"); t.interrupt(); System.out.println("线程的中断状态2:" + t.isInterrupted()); } }
I am running!
I am running!
I am running!
I am running!
I am running!
I am running!
I am running!
I am running!
I am running!
I am running!
I am running!
I am running!
I am running!
I am running!
I am running!
*****************************
Interrupted Thread!
*****************************
线程的中断状态2:true
第二次调用Thread.interrupted()方法:false
注:本文源自互联网,经过查阅网上资料整理而成,如涉及到他人整理的成果,在此表示感谢。由于涉及到的参考文章比较多,在此就不再一一列举。
本文是目前个人理解的结果,仅供参考,如后续发现问题,本人会进行相应的更正,也欢迎各位对Java线程感兴趣的朋友或者前辈进行指正。
上一篇: ftp
下一篇: *学Vue——Axios异步通信