「这是我参与2022首次更文挑战的第2天,活动详情查看:2022首次更文挑战」
介绍
Java的中断是一种协作机制,也就是说通过中断并不能直接中断另外一个线程,而需要被中断的线程自己处理中断。
在Java的中断模型中,每个线程都有一个boolean标识,代表着是否有中断请求(该请求可以来自所有线程,包括被中断的线程本身)。例如,当线程t1想中断线程t2,只需要在线程t1中将线程t2对象的中断标识置为true,然后线程2可以选择在合适的时候处理该中断请求,甚至可以不理会该请求,就像这个线程没有被中断一样。
中断方法
线程中断相关的方法主要是下面的3方法,他们具体的作用见下面的表格:
方法名 | 介绍 |
---|---|
void interrupt() | 中断线程,设置线程的中断位true |
boolean isInterrupted() | 检查线程的中断标记位,true-中断状态, false-非中断状态 |
static boolean interrupted() | 静态方法,返回当前线程的中断标记位,同时清除中断标记,改为false。比如当前线程已中断,调用interrupted(),返回true, 同时将当前线程的中断标记位改为false, 再次调用interrupted(),会发现返回false |
记忆方法推荐:
- interrupt()是一个动词,表示中断线程。
- Interrupted是一个形容词,用于检查线程的中断位,而isInterrupted()方法只是简单的检查,interrupted()处理的更加复杂。
可中断的阻塞
针对线程处于由sleep
, wait
, join
,LockSupport.park
等方法调用产生的阻塞状态时,调用interrupt方法,会抛出异常InterruptedException
,同时会清除中断标记位,自动改为false。
不可中断的阻塞
- java.io包中的同步Socket I/O
- java.io包中的同步I/O
- Selector的异步I/O
sychronized
加的锁
实践案例
中断sleep、wait、join等方法
private static void test1() throws InterruptedException {
Thread t1 = new Thread(() -> {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
log.error("error", e);
}
}, "t1");
t1.start();
Thread.sleep(500);
t1.interrupt();
Thread.sleep(100);
log.info(" interrupt status : {}", t1.isInterrupted());
}
复制代码
结论: 阻塞方法sleep响应中断,抛出InterruptedException
,同时清除中断标记位为false。
中断正常方法
private static void test2() throws InterruptedException {
Thread t2 = new Thread(() -> {
while (true) {
boolean isInterrupted = Thread.currentThread().isInterrupted();
if (isInterrupted) {
log.info("interrupt status: {}", isInterrupted);
break;
}
}
}, "t2");
t2.start();
Thread.sleep(500);
t2.interrupt();
Thread.sleep(100);
log.info(" thread status, {}, interrupt status : {}", t2.getState(), t2.isInterrupted());
}
复制代码
结论: 打断正常运行的线程, 不会清空打断状态,同时线程结束后,重置中断状态位。