Thread.interrupt() 使用不当,导致程序无法退出

简介:

http://blog.chenlb.com/2009/07/incorrect-use-thread-interrupt-cause-not-exit.html


Java Thread.interrupt() 使用不当,导致多线程程序无法正常退出。前段时间写的一个多线程程序:一个子线程基本是死循环地从任务池里取出任务(取的时候,没有任务会阻塞),并运行可用的任务。没有任务了,完成的时候 main 线程调用子线程的中断,抓到中断后退出子线程的死循环。

上面的程序已经正常的运行了几个月了,是一天运行一次而已。近期要在每4分钟运行一次的应用中使用了这程序。运行一天多就会阻塞掉了(一直不会退出),今天是第二次了。观察分析日志:是在 main 调用 taskThread.interrupt() 会没有输出日志(实际就是没有中断到子线程),而死循环是在接受到中断才会把循环条件设为 false。所以程序 block了,不退出了。

分析:调用 taskThread.interrupt() 为什么没有接受到中断(实际是 InterruptedException)呢?找原理:Thread.interrupt() 的调用对正在运行的线程是不起作用的,只有对阻塞的线程有效。下面是引用:Java Thread.interrupt 害人! 中断JAVA线程(zz) 的一段重要的话。

使用Thread.interrupt()中断线程

Thread.interrupt()方法不会中断一个正在运行的线程。这一方法实际上完成的是,在线程受到阻塞时抛出一个中断信号,这样线程就得以退出阻塞的状态。更确切的说,如果线程被Object.wait, Thread.join和Thread.sleep三种方法之一阻塞,那么,它将接收到一个中断异常(InterruptedException),从而提早地终结被阻塞状态。

因此,如果线程被上述几种方法阻塞,正确的停止线程方式是设置共享变量,并调用interrupt()(注意变量应该先设置)。如果线程没有被阻塞,这时调用interrupt()将不起作用;否则,线程就将得到异常(该线程必须事先预备好处理此状况),接着逃离阻塞状态。在任何一种情况中,最后线程都将检查共享变量然后再停止。

程序代码块大概:

public void run() {  
    while(running) {  
        Object obj = null;  
        try {  
            //...  
            //取出数据  
            obj = taskQueue.take();  
            //执行任务...  
        } catch (InterruptedException e) {  
            running = false;  
            log.info("被 interrupt, 退出");  
        }  
  
    }   //while  
    //....  
}  

描述现在的程序:使子线程阻塞的地方是从任务池取数据,具体来说是 java.util.concurrent.LinkedBlockingQueue.take() 方法。它在 try/catch 内,catch 到 InterruptedException 设置执行任务的循环条件变量。然后就退出 run。我草率地认为interrupt被调用了(认为take会被阻塞,有一段每200ms检测全部任务是否完成),一定能 catch 到中断。也没有在调用 taskThread.interrupt() 之前把循环条件变量设为 false。所以造成有时候子线程不能退出。

当执行最后一个任务还没有完成时,main 调用 taskThread.interrupt() 就会失效,因为子线程没有 blocking。

解决办法是在调用 interrupt 之前,running = false。


相关文章
|
4月前
start.S详解学习(六):异常中断处理
start.S详解学习(六):异常中断处理
32 0
|
10月前
三种方式中断运行的线程?(interrupt 方法)
三种方式中断运行的线程?(interrupt 方法)
67 0
|
监控
【多线程:interrupt 方法详解】
【多线程:interrupt 方法详解】
131 0
|
12月前
|
Java API
高并发编程-Thread_正确关闭线程的三种方式
高并发编程-Thread_正确关闭线程的三种方式
167 0
|
API
如何让一个线程“优雅”地退出
如何让一个线程“优雅”地退出
138 0
|
调度
多线程(Thread类、线程创建、中断、等待、休眠)
多线程(Thread类、线程创建、中断、等待、休眠)
153 0
|
物联网 Linux 开发者
线程 pthread_exit 时执行清理程序|学习笔记
快速学习线程 pthread_exit 时执行清理程序
132 0
线程 pthread_exit 时执行清理程序|学习笔记
Java多线程:如何停止/中断一个运行中的线程?
Java多线程:如何停止/中断一个运行中的线程?
Java多线程:如何停止/中断一个运行中的线程?