为什么在catch InterruptException块中调用Thread.currentThread.interrupt()？

Question

为什么在catch块中调用Thread.currentThread.interrupt()方法？

Answer 1

这样做是为了保持状态.

当你捕获InterruptException并吞下它时,你基本上阻止任何更高级别的方法/线程组注意到中断.这可能会导致问题.

通过调用Thread.currentThread().interrupt(),您可以设置线程的中断标志,因此更高级别的中断处理程序会注意到它并且可以适当地处理它.

Java Concurrency in Practice在第7.1.3章:响应中断中更详细地讨论了这一点.它的规则是:

只有实现线程中断策略的代码才可以吞下中断请求.通用任务和库代码永远不应吞下中断请求.

Answer 2

我认为这个代码示例使事情变得清晰.完成工作的班级:

   public class InterruptedSleepingThread extends Thread {

        @Override
        public void run() {
            doAPseudoHeavyWeightJob();
        }

        private void doAPseudoHeavyWeightJob() {
            for (int i=0;i<Integer.MAX_VALUE;i++) {
                //You are kidding me
                System.out.println(i + " " + i*2);
                //Let me sleep <evil grin>
                if(Thread.currentThread().isInterrupted()) {
                    System.out.println("Thread interrupted\n Exiting...");
                    break;
                }else {
                    sleepBabySleep();
                }
            }
        }

        /**
         *
         */
        protected void sleepBabySleep() {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                //e.printStackTrace();
                Thread.currentThread().interrupt();
            }
        }
    }

主类:

   public class InterruptedSleepingThreadMain {

        /**
         * @param args
         * @throws InterruptedException
         */
        public static void main(String[] args) throws InterruptedException {
            InterruptedSleepingThread thread = new InterruptedSleepingThread();
            thread.start();
            //Giving 10 seconds to finish the job.
            Thread.sleep(10000);
            //Let me interrupt
            thread.interrupt();
        }

    }

尝试在不设置状态的情况下调用中断.

Answer 3

注意:

http://download.oracle.com/javase/7/docs/technotes/guides/concurrency/threadPrimitiveDeprecation.html

如何停止等待很长时间的线程(例如,输入)？

要使此技术起作用,任何捕获中断异常并且不准备立即处理它的方法都必须重新确认异常.我们说重申而不是重新抛出,因为并不总是可以重新抛出异常.如果没有声明捕获InterruptedException的方法抛出此(已检查)异常,那么它应该使用以下咒语"重新中断":

Thread.currentThread().interrupt();

这可以确保Thread一旦能够就重新加入InterruptedException.