Java Thread中的interrupt方法使用详解

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()将不起作用；否则，线程就将得到异常（该线程必须事先预备好处理此状况），接着逃离阻塞状态。在任何一种情况中，最后线程都将检查共享变量然后再停止。

程序代码块大概：

   1. public void run() { 
   2.     while(running) { 
   3.         Object obj = null; 
   4.         try { 
   5.             //... 
   6.             //取出数据 
   7.             obj = taskQueue.take(); 
   8.             //执行任务... 
   9.         } catch (InterruptedException e) { 
  10.             running = false; 
  11.             log.info("被 interrupt, 退出"); 
  12.         } 
  13.  
  14.     }   //while 
  15.     //.... 
  16. } 

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。