JavaRush/Помощь по Java задачам/interrupt и interruptedexception

22 уровень

25.07.2018
6891просмотров
9комментариев

interrupt и interruptedexception

Решен

исключение выбрасывается только в случае, если поток находится в режиме ожидания чего-то или при любом включении флага прерывания в положение true? например:

public void run(){
interrupt();
Thread.sleep(100);
}

public void run(){
interrupt();
}

исключение выбросится в обоих случаях или только в первом?

Комментарии (9)

популярные
новые
старые

Для того, чтобы оставить комментарий Вы должны авторизоваться

Илья Геков

Уровень 40

Master

25 июля 2018, 17:49

решение

Для наглядности протестируйте эти два варианта кода:

public static void main(String[] args) {
        new Thread(new Runnable() {
            @Override
            public void run() {
                while (true) {
                    System.out.println(Thread.currentThread().isInterrupted());
                    Thread.currentThread().interrupt();
                }
            }
        }).start();
    }

public static void main(String[] args) {
        new Thread(new Runnable() {
            @Override
            public void run() {
                while (!Thread.currentThread().isInterrupted()) {
                    System.out.println(Thread.currentThread().isInterrupted());
                    Thread.currentThread().interrupt();
                    System.out.println(Thread.currentThread().isInterrupted());
                }
            }
        }).start();
    }

В первом варианте мы не проверяем в цикле interrupted поток или нет (а он таковым становится при первом же шаге цикла, но поток продолжит работать бесконечно). Во втором варианте interrupted - условие цикла, соответственно как только поток становится interrupted цикл завершается, run тоже, поток заканчивает работу.

Илья Геков

Уровень 40

Master

25 июля 2018, 17:38

https://habr.com/post/164487/ хорошая статься на тему. "У методов, приостанавливающих выполнение потока, таких как sleep(), wait() и join() есть одна особенность — если во время их выполнения будет вызван метод interrupt() этого потока, они, не дожидаясь конца времени ожидания, сгенерируют исключение InterruptedException." interrupt - это просто флаг, обозначающий, что поток нужно прервать. Если по этому флагу нужно прервать поток, то в соответствующих частях кода задачи потока нужно вставить проверку на этот флаг и, к примеру, сделать пустой return, завершив тем самым выполнение метода run и потока.

Андрей

Уровень 22

26 июля 2018, 17:14

я сам в лекции кидал ссылку на эту статью)) тут такая история. я в потоке вызвал interrupt, потом sleep и поток кинул исключение. вопрос заключался в том, что если бы не было sleep, выбросилось бы исключение или нет. но если бы не было sleep, то не было бы и ловушки для исключения... теперь допер. получается, что поток завершится только если мы ставим цикл на флаг, либо в спящий поток (без проверки флага) кидаем interrupt и он завершается исключением? да. проверил кодом:

public void run() {
            System.out.println("before");
                try {
                    Thread.sleep(1000);
                    interrupt();
                    System.out.println("after");
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    System.out.println("exception");
                }
        }

если закомментить второй sleep, то исключения не будет. я так понимаю, что проверка флага для выброса исключения идет во время сна?

Илья Геков

Уровень 40

Master

26 июля 2018, 17:50

Суть в том, что когда поток не спит, мы можем сами настроить проверку флага в нужных нам местах, но если поток в ожидании(а это ожидание может быть сколько угодно долгим), мы не можем своим кодом заставить поток проверить флаг, поэтому для этого случая и бросается исключение, которое мы можем (а точнее обязаны - иначе компилятор не пропустит) обработать по своему усмотрению. То есть нельзя сказать, что поток "завершается исключением", поток завершиться тогда, когда вы решите в своем коде, а исключение нужно лишь для того, чтобы его обработать и решить, что делать дальше (обратите внимание, вы не можете пробросить исключение выше по стеку до main, вы обязаны его обработать).

Илья Геков

Уровень 40

Master

26 июля 2018, 17:53

Еще советую, если не смотрели, лекции Ивана Головача на ютубе про многопоточность(и не только), очень подробно и доступно

Илья Геков

Уровень 40

Master

26 июля 2018, 18:05

Вот еще два примера:

public static void main(String[] args) throws IOException {

         new Thread(new Runnable() {
             @Override
             public void run() {
                 while (true) {
                     try {
                         TimeUnit.SECONDS.sleep(1);
                         Thread.currentThread().interrupt();
                     } catch (InterruptedException e) {
                         System.out.println("Thread is interrupted");
                     }
                 }
             }
         }).start();
    }



public static void main(String[] args) throws IOException {

         new Thread(new Runnable() {
             @Override
             public void run() {
                 while (!Thread.currentThread().isInterrupted()) {
                     try {
                         TimeUnit.SECONDS.sleep(1);
                         Thread.currentThread().interrupt();
                     } catch (InterruptedException e) {
                         System.out.println("Thread is interrupted");
                     }
                 }
             }
         }).start();
    }

И там и там выбрасывается исключение во время sleep, но в первом случае поток продолжает работу, а во втором прекращает после первого шага цикла, почему? Когда выбрасывается исключение, мы его обрабатываем в catch блоке, выводим в данном случае сообщение на экран и все, цикл продолжает работу, снова выбрасывает исключение, снова обрабатывается и т.д. до бесконечности. Во втором случае в цикле мы проверяем флаг, соответственно после обработки исключения, стартует новый шаг цикла, проверяется условие, оно не выполняется, цикл завершается, поток закругляется. В первом случае мы могли выйти из потока просто добавив return в catch блок, но второй вариант все же выглядит логичнее.

Андрей

Уровень 22

27 июля 2018, 11:42

я еще поизучаю. спасибо. головача смотрел - уже задолбался)) т.е. выбрасывание исключения != прерыванию потока? когда закончится мое отсутствие знаний по прерыванию!?!?!?((( так. уточнение. потоки у вас крутятся благодаря while(true). а если без этого бесконечного цикла? просто начали run, поток уснул и ему посылается interrupt, то что тогда происходит?

Илья Геков

Уровень 40

Master

27 июля 2018, 14:47

Опять же, произойдет то, что вы заложите в catch блок, может вы захотите в этом случае еще какой метод вызвать или еще что, не важно. Если оставите пустым catch блок, цикла нет, после catch блока других команд нет, то естественно нить закончит работу, но не потому что исключение вылетело, а потому что собственно методу run больше нечего делать. Вот такой пример, по которому видно, что исключение != прерывание потока:

public static void main(String[] args) throws IOException {

        Thread t = new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    TimeUnit.SECONDS.sleep(2);
                } catch (InterruptedException e) {
                    System.out.println("Исключение выбросилось");
                }

                System.out.println("Но поток продолжает работу");
            }
        });

        t.start();
        t.interrupt();
    }
}

Исключение вылетает, обрабатывается, на консоль выводится первая строка, после чего поток продолжает работу и, только завершив код метода run до конца (напечатав вторую строку), завершается.

Андрей

Уровень 22

28 июля 2018, 15:28

Я понял. Спасибо большое!