Зачем вызывать Thread.currentThread.interrupt () в блоке перехвата InterruptException? - PullRequest
Новая
       1

Зачем вызывать Thread.currentThread.interrupt () в блоке перехвата InterruptException?

128 голосов
/ 05 февраля 2011

Зачем вызывать метод Thread.currentThread.interrupt () в блоке catch?

Ответы [ 4 ]

141 голосов
/ 05 февраля 2011

Это делается для сохранения состояния .

Когда вы перехватываете InterruptException и проглатываете его, вы по существу не позволяете любым методам / группам потоков более высокого уровня замечать прерывание. Что может вызвать проблемы.

Вызывая Thread.currentThread().interrupt(), вы устанавливаете флаг прерывания потока, поэтому обработчики прерываний более высокого уровня заметят это и смогут обработать его соответствующим образом.

Java-параллелизм на практике обсуждает это более подробно в Глава 7.1.3: Реакция на прерывание . Его правило:

Только код, реализующий политику прерывания потока, может проглотить запрос прерывания. Универсальный код задачи и библиотеки никогда не должен поглощать запросы прерывания.

58 голосов
/ 19 июля 2011

Я думаю, что этот пример кода проясняет ситуацию. Класс, который делает работу: 

   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();
        }

    }

Попробуйте вызвать прерывание без возврата статуса.

20 голосов
/ 05 февраля 2011

Примечание:

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

Как остановить поток, ожидающий длительные периоды (например, для ввода)?

Чтобы этот метод работал, очень важно, чтобы любой метод, который перехватывает исключение прерывания и не готов обработать его, немедленно переустанавливает исключение. Мы говорим, скорее, подтверждает, а не отбрасывает, потому что не всегда возможно отбросить исключение. Если метод, который перехватывает InterruptedException, не объявлен, чтобы вызвать это (проверенное) исключение, то он должен "прервать себя" следующим заклинанием: 

Thread.currentThread().interrupt();

Это гарантирует, что Поток повторно вызовет InterruptedException, как только сможет.

2 голосов
/ 05 февраля 2011

Я бы посчитал это плохой практикой или хотя бы немного рискованной. Обычно методы более высокого уровня не выполняют блокирующих операций и никогда не увидят InterruptedException там. Если вы маскируете его в каждом месте, где выполняете прерываемую операцию, вы никогда не получите его.

Единственное обоснование для Thread.currentThread.interrupt() и отсутствие вызова какого-либо другого исключения или сигнализации о прерывании каким-либо другим способом (например, установка interrupted переменной локальной переменной в главном цикле потока) - это ситуация, когда вы действительно ничего не можете сделать за исключением, как в блоках finally.

См. Ответ Петера Торока, если вы хотите лучше понять последствия вызова Thread.currentThread.interrupt().

...