在学习Java的过程中,多线程一直以来就是Java中的比较难的知识点,但是多线程又是那么的重要。在实际的开发中,多线程也是常见的。本文将介绍在多线程中怎么正确的中断线程,不会介绍多线程的基知识。
1. 前言
在Java的线程中,只有线程的run方法运行完毕,才算线程真正的结束。通常来说,一种情况是run方法正确无误的运行完毕,还有一种情况是在run方法里面抛出了异常并且没有捕获,导致线程异常终止。
在早期的Java版本中,有一个stop方法,可以终止一个线程。但是这个方法已经被弃用了。
在现如今的Java版本中,没有强制终止线程的方法。然而,我们可以通过interrupt方法来请求终止线程,这个操作需要程序员自己来实现。接下来会介绍interrupt方法的用法。
当我们对一个线程调用interrupt方法时,线程有一个中断状态标志位将会被重置。这个标志位每一个线程都有。我们在构建自己的多线程时,应该时不时的检查这个标志位,以判断当前线程是否需要终止。
例如:
@Override
public void run() {
while (true) {
if (Thread.currentThread().isInterrupted()) {//中断状态标志位被重置
//退出死循环,结束run方法
break;
} else { //没有被重置
//do your work
}
}
}
这里我举了一个简单的例子。我们在run方法中增加了一个判断条件,只有当前的中断标志位为false才进行运行的,否则就跳出死循环,此时当前的线程生命就就结束了。此时,如果我们在其他线程里面想要中断这个线程,只需要调用interrupt方法就行了。
2. InterruptException异常产生的原因
关于InterruptException异常,只要熟悉多线程的朋友可能都会认识,当我们在调用Thread.sleep方法时,就会抛出这个异常,这里将介绍InterruptException异常的原因,并且将介绍这个异常造成的结果。
前面我们已经知道了,我们可以调用interrupt方法来重置当前线程的中断状态标志位。但是我们在调用这个方法,有一个问题,如果当前的线程被阻塞了(线程的阻塞方式有很多, 比如,被Scanner阻塞,sleep,wait),是无法检测到中断状态,如果此时调用interrupt方法,在阻塞的位置会抛出一个异常,那就是InterruptException异常。这个也能解释,为什么我们在调用sleep方法时,会抛出InterruptException方法。如果线程产生了InterruptException异常,会被异常中断(也存在不能被中断的线程阻塞,比如IO访问)。
3. sleep方法的正确使用
由于sleep方法会抛出InterruptException异常,所以在一个线程如何使用sleep方法就变得格外不一样。为什么不一样呢?可能各位朋友会这样写代码:
Thread thread = new Thread(() -> {
while (true) {
try {
Thread.sleep(500);
// 这里的线程工作就是不断打印1
System.out.println(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
if(Thread.currentThread().isInterrupted()) {
break;
}
}
});
这个代码通常来说没有人写,这里只是为了举一个例子。这个代码感觉是没有任何的问题,如果此时,我们这样调用的话:
thread.start();
thread.interrupt();
那么会出现一个奇怪的现象,就是我们调用interrupt方法,线程不会停止。这个又是什么原因呢?我们先按照常规的思维来思考一下:调用start方法线程开启,先sleep,此时外部调用interrupt方法来重置中断状态标志位,将flag(假设为中断状态标志位)重置为true,但是此时会抛出一个InterruptException,这个的原因,我们在之前已经说了,当前的线程被sleep方法阻塞了,此时如果在调用当前的interrupt方法,会抛出异常。抛出异常之后,进入catch,这个没的说,此时再进入if判断语句,如果当前的flag为true,就会退出循环。
实际上,在整个过程中,线程被sleep方法阻塞了,但是产生了InterruptException异常时,此时线程不会继续睡眠,而是马上抛出异常,而且会清除flag的状态,也就是将flag变为false。
我们建议这样做:
Thread thread = new Thread(() -> {
try {
while (true) {
Thread.sleep(500);
// 这里的线程工作就是不断打印1
System.out.println(1);
if (Thread.currentThread().isInterrupted()) {
break;
}
}
} catch (InterruptedException e) {
e.printStackTrace();
}
});