线程中断是协作机制,调用interrupt()设置中断标志,线程需主动通过isInterrupted()检查或捕获InterruptedException响应;阻塞方法中断后会抛出异常并清除标志,应重新设置中断状态,循环中也需定期检查中断,避免忽略中断请求,确保线程安全可控退出。
Java中的线程中断机制并不是强制终止线程,而是一种协作式的通信方式,用于通知线程“应该停止当前工作”。正确实现中断机制需要理解interrupt()、isInterrupted()和InterruptedException的使用。
每个线程都有一个中断状态标志位。调用线程的interrupt()方法会设置该标志位。线程可以通过isInterrupted()方法检查自身是否被中断。中断本身不会停止线程运行,只是提供一个信号,由线程自行决定如何响应。
Thread thread = new Thread(() -> {
while (!Thread.currentThread().isInterrupted()) {
// 执行任务
System.out.println("线程运行中...");
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
System.out.println("sleep被中断");
// 重新设置中断状态
Thread.currentThread().interrupt();
}
}
System.out.println("线程正常退出");
});
thread.start();
// 主线程延迟后中断目标线程
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
thread.interrupt();
某些方法如sleep()、wait()、join()等是可中断的,当线程在这些方法中被中断时,会抛出InterruptedException,同时中断标志会被清除。
捕获到InterruptedException后,通常有两种处理方式:
在catch块中调用Thread.currentThread().interrupt()恢复中断状态,尤其是你无法立即结束线程时。
对于长时间运行的计算任务,应主动在循环中检查中断状态,及时响应中断请求。
示例:
while (true) {
// 模拟耗时计算
doSomeCalculation();
if (Thread.currentThread().isInterrupted()) {
System.out.println("收到中断信号,准备退出");
cleanup();
break;
}
}
不要吞掉InterruptedException。即使你想继续执行,也应保留中断信号。
} catch (InterruptedException e) {
// 什么也不做,中断被忽略
}
正确做法:
} catch (InterruptedException e) {
Thread.current
Thread().interrupt(); // 恢复中断
break;
}
基本上就这些。关键是理解中断是一种协作机制,线程必须主动检查并响应中断请求,特别是在阻塞和循环场景中。合理使用中断能写出更安全、可控的多线程程序。不复杂但容易忽略细节。