如何优雅的"中断"一个线程?
线程的启动过程大家都非常熟悉,但是如何终止一个线程,我相信绝大部分人在面试的时候被问到这个问题时,也会不知所措,不知道怎么回答。
记住,线程的终止,并不是简单的调用 stop 命令去。虽然 api 仍然可以调用,但是和其他的线程控制方法如 suspend、resume 一样都是过期了的不建议使用,就拿stop 来说,stop 方法在结束一个线程时并不会保证线程的资源正常释放,因此会导致程序可能出现一些不确定的状态。
要优雅的去中断一个线程,在线程中提供了一个 interrupt 方法。
interrupt 方法
当其他线程通过调用当前线程的 interrupt 方法,表示向当前线程打个招呼,告诉他可以中断线程的执行了,至于什么时候中断,取决于当前线程自己。 线程通过检查资深是否被中断来进行相应,可以通过 isInterrupted()来判断是否被中断。
通过下面这个例子,来实现了线程终止的逻辑 :
public class ThreadInterruptDemo {
/* public static void main(String[] args) throws InterruptedException {
Thread thred=new Thread(()->{
while(true){
boolean in=Thread.currentThread().isInterrupted();
if(in){
System.out.println("before:"+in);
Thread.interrupted();//设置复位
System.out.println("after:"+Thread.currentThread().isInterrupted());
}
}
});
thred.start();
TimeUnit.SECONDS.sleep(1);
thred.interrupt(); //终端
}*/
/* public static void main(String[] args) throws InterruptedException {
Thread thread=new Thread(()->{
while(true){
try {
Thread.sleep(10000000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});
thread.start();
TimeUnit.SECONDS.sleep(1);
thread.interrupt();
System.out.println("before:"+thread.isInterrupted());
TimeUnit.SECONDS.sleep(1);
System.out.println("after:"+thread.isInterrupted());
}*/
// volatile boolean stop=true;
}
这种通过标识位或者中断操作的方式能够使线程在终止时有机会去清理资源,而不是武断地将线程停止,因此这种终止线程的做法显得更加安全和优雅.
通过 interrupt,设置了一个标识告诉线程可以终止了,线程中还提供了静态方法 Thread.interrupted()对设置中断标识的线程复位。比如在上面的案例中,外面的线程调用 thread.interrupt 来设置中断标识,而在线程里面,又通过Thread.interrupted 把线程的标识又进行了复位 .
image.png
除了通过Thread.interrupted 方法对线程中断标识进行复位以外,还有一种被动复位的场景,就是对抛出 InterruptedException 异常的方法,在InterruptedException 抛出之前,JVM 会先把线程的中断标识位清除,然后才会抛出InterruptedException,这个时候如果调用 isInterrupted 方法,将会返回false .
image.png
我们可以看下jvm中的源代码,看下1为什么要复位。
image.png
image.png
可以看到,其实就是通过unpark 去唤醒当前线程,并且设置一个标识位为 true。 并没有所谓的中断线程的操作,所以实际上,线程复位可以用来实现多个线程之间的通信。
线程的停止方法之2
除了通过interrupt 标识为去中断线程以外,我们还可以通过下面这种方式,定义一个volatile 修饰的成员变量,来控制线程的终止。这实际上是应用了volatile 能够实现多线程之间共享变量的可见性这一特点来实现的。
image.png