合理打断处于阻塞的线程状态

合理打断处于阻塞的线程状态

一、方法

二、使用

1. 打断 sleep，wait，join 的线程

这几个方法都会让线程进入阻塞状态
打断 sleep 的线程, 会清空打断状态，以 sleep 为例

Thread t1 = new Thread(()-> {//sleep(1);//try {//    Thread.currentThread().join();//} catch (InterruptedException e) {//    e.printStackTrace();//}try {Thread.currentThread().wait();} catch (InterruptedException e) {e.printStackTrace();}}, "t1");
t1.start();
sleep(0.5);
t1.interrupt();
log.debug(" 打断状态: {}", t1.isInterrupted());

输出

sleep：

java.lang.InterruptedException: sleep interrupted
at java.lang.Thread.sleep(Native Method)
at java.lang.Thread.sleep(Thread.java:340)
at urrent.TimeUnit.sleep(TimeUnit.java:386)
at cn.itcast.n2.util.Sleeper.sleep(Sleeper.java:8)
at cn.itcast.n4.TestInterrupt.lambda$test1$3(TestInterrupt.java:59)
at java.lang.Thread.run(Thread.java:745)
21:18:10.374 [main] c.TestInterrupt - 打断状态: false

wait：

Exception in thread "t1" java.lang.IllegalMonitorStateExceptionat java.lang.Object.wait(Native Method)at java.lang.Object.wait(Object.java:502)at st.Test.lambda$main$0(Test.java:30)at java.lang.Thread.run(Thread.java:748)
15:37:32.974 c.Test [main] -  打断状态: false

join：

java.lang.InterruptedExceptionat java.lang.Object.wait(Native Method)at java.lang.Thread.join(Thread.java:1252)at java.lang.Thread.join(Thread.java:1326)at st.Test.lambda$main$0(Test.java:25)at java.lang.Thread.run(Thread.java:748)
15:46:22.178 c.Test [main] -  打断状态: false

2. 打断正常运行的线程

打断正常运行的线程, 不会清空打断状态

private static void test2() throws InterruptedException {Thread t2 = new Thread(()->{while(true) {Thread current = Thread.currentThread();boolean interrupted = current.isInterrupted();if(interrupted) {log.debug(" 打断状态: {}", interrupted);break;}}}, "t2");t2.start();sleep(0.5);t2.interrupt();
}  

输出

20:57:37.964 [t2] c.TestInterrupt - 打断状态: true  

3. 打断 park 线程

打断 park 线程, 不会清空打断状态

private static void test3() throws InterruptedException {Thread t1 = new Thread(() -> {log.debug(&#");LockSupport.park();log.debug(&#");log.debug("打断状态：{}", Thread.currentThread().isInterrupted());}, "t1");t1.start();sleep(0.5);t1.interrupt();
}

输出

21:11:52.795 [t1] c.TestInterrupt - 
21:11:53.295 [t1] c.TestInterrupt - 
21:11:53.295 [t1] c.TestInterrupt - 打断状态：true

如果打断标记已经是 true, 则 park 会失效

private static void test4() {Thread t1 = new Thread(() -> {for (int i = 0; i < 5; i++) {log.debug(&#");LockSupport.park();log.debug("打断状态：{}", Thread.currentThread().isInterrupted());}// 清除 打断标记，即 设置为 falseThread.interrupted();log.debug("打断状态：{}", Thread.currentThread().isInterrupted());log.debug(&#");LockSupport.park();log.debug("打断状态：{}", Thread.currentThread().isInterrupted());});t1.start();sleep(1);t1.interrupt();
}

输出

15:54:57.684 c.Test [Thread-0] - 
15:54:58.692 c.Test [Thread-0] - 打断状态：true
15:54:58.696 c.Test [Thread-0] - 
15:54:58.696 c.Test [Thread-0] - 打断状态：true
15:54:58.696 c.Test [Thread-0] - 
15:54:58.696 c.Test [Thread-0] - 打断状态：true
15:54:58.696 c.Test [Thread-0] - 
15:54:58.696 c.Test [Thread-0] - 打断状态：true
15:54:58.696 c.Test [Thread-0] - 
15:54:58.696 c.Test [Thread-0] - 打断状态：true
15:54:58.696 c.Test [Thread-0] - 打断状态：false
15:54:58.696 c.Test [Thread-0] - 
# 还有 下一句打断标记没打印出来，此时已恢复 park 功能

提示
可以使用 Thread.interrupted() 清除打断状态

总结：

• 处于sleep、join、wait 状态的线程 使用 interrupt() 会清除打断标记 Thread.currentThread().isInterrupted())

• 处于park和 run 的线程，使用 interrupt()不会清除打断标记 Thread.currentThread().isInterrupted())

• park线程 调用 interrupt()后，该线程后面再使用的 park会失效，需要使用 Thread.interrupted() 恢复park 为有效

三、结束语

评论区可留言，可私信，可互相交流学习，共同进步，欢迎各位给出意见或评价，本人致力于做到优质文章，希望能有幸拜读各位的建议！

专注品质，热爱生活。
交流技术，奢求同志。