JavaRush/Помощь по Java задачам/Не проходит 4 пункт.

20 уровень

10.01.2019
1421просмотров
14комментариев

Не проходит 4 пункт.

Вопрос по задаче

Решен

Валидатор утверждает что 4 поток должен реализовывать интерфейс Message. Хотя он вроде как реализован. Делал и через логический флаг и теперь вот через interrupt(). Наследование делал и через Thread (сейчас эта версия), также и runnable реализовывал (как в других нитях). Короче не пойму. похоже что какая-то мелочь, но не могу сообразить..

1. Создай 5 различных своих нитей (наследников класса Thread):
1.1. Нить 1 должна бесконечно выполняться;
1.2. Нить 2 должна выводить "InterruptedException" при возникновении исключения InterruptedException;
1.3. Нить 3 должна каждые полсекунды выводить "Ура";
1.4. Нить 4 должна реализовать интерфейс Message, при вызове метода showWarning нить должна останавливаться;
1.5. Нить 5 должна читать с консоли числа пока не введено слово "N", а потом вывести в консоль сумму введенных чисел.
2. В статическом блоке добавь свои нити в List<Thread> threads в перечисленном порядке.
3. Нити не должны стартовать автоматически.

Подсказка:
Нить 4 можно проверить методом isAlive()

Требования:

Статический блок класса Solution должен создавать и добавлять 5 нитей в список threads.
Нити из списка threads не должны стартовать автоматически.
Нить 1 из списка threads должна бесконечно выполняться.
Нить 2 из списка threads должна выводить "InterruptedException" при возникновении исключения InterruptedException.
Нить 3 из списка threads должна каждые полсекунды выводить "Ура".
Нить 4 из списка threads должна реализовать интерфейс Message, при вызове метода showWarning нить должна останавливаться.
Нить 5 из списка threads должна читать с консоли числа пока не введено слово "N", а потом вывести в консоль сумму введенных чисел.

package com.javarush.task.task16.task1632; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.util.ArrayList; import java.util.List; public class Solution { public static List<Thread> threads = new ArrayList<>(5); static { threads.add(new Thread(new firstThread())); threads.add(new Thread(new secondThread())); threads.add(new Thread(new thirdThread())); threads.add(new Thread(new fourthThread())); threads.add(new Thread(new fifthThread())); } public static void main(String[] args) { for (Thread t: threads) { t.start(); } ((fourthThread)threads.get(3)).showWarning(); } public static class firstThread implements Runnable { @Override public void run() { while (true) { } } } public static class secondThread implements Runnable { @Override public void run() { try { while (true) { Thread.sleep(1); } } catch (InterruptedException e) { System.out.println("InterruptedException"); } } } public static class thirdThread implements Runnable { @Override public void run() { try { while (true) { System.out.println("Ура"); Thread.sleep(500); } } catch (InterruptedException e) { } } } public static class fourthThread extends Thread implements Message { @Override public void showWarning() { Thread.currentThread().interrupt(); } @Override public void run() { while (!isInterrupted()) { } } } public static class fifthThread implements Runnable{ @Override public void run() { BufferedReader reader = new BufferedReader(new InputStreamReader(System.in)); int sum = 0; while (true){ try{ String s = reader.readLine(); if(s.equals("N")) break; int i = Integer.parseInt(s); sum += i; }catch (Exception e){ } } System.out.println(sum); } } }

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

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

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

Максим Кобыляков

Уровень 41

13 января 2019, 09:05

ну тогда я за то что ему нужен отдельный файл

Sergey Moroz

Уровень 26

Expert

10 января 2019, 14:17

Ты подсказку к 4 нити проигнорил - Валя обиделась

Максим Кобыляков

Уровень 41

10 января 2019, 13:43

у меня он вот такой package com.javarush.task.task16.task1632; public class MessageThread extends Thread implements Message { private boolean unstoppedThread = true; @Override public void showWarning() { this.unstoppedThread = false; } @Override public void run() { try { while (this.unstoppedThread) { Thread.sleep(100); } } catch (InterruptedException e) { } } } вроде сам писал но давно

Ильнар

Уровень 20

10 января 2019, 14:05

Это первый вариант решения, который я сам писал (правда я в цикле не ставил Thread.sleep(100)). Но на всякий скопировал Ваш код к себе и попробовал пройти валидатор. Ситуация не изменилась. (отличие от Вашего кода лишь в том, что класс не в отдельном файле, а посему static, в остальном полный копипаст).

public class Solution {
    public static List<Thread> threads = new ArrayList<>(5);

    static {
        threads.add(new Thread(new firstThread()));
        threads.add(new Thread(new secondThread()));
        threads.add(new Thread(new thirdThread()));
        threads.add(new Thread(new fourthThread()));
        threads.add(new Thread(new fifthThread()));
    }

    public static void main(String[] args) {
        for (Thread t: threads) {
            t.start();
        }
        ((fourthThread)threads.get(3)).showWarning();
    }


    public static class fourthThread extends Thread implements Message {
        private boolean unstoppedThread = true;

        @Override
        public void showWarning() {
            this.unstoppedThread = false;
        }

        @Override
        public void run() {
            try {
                while (this.unstoppedThread) {
                    Thread.sleep(100);
                }
            } catch (InterruptedException e) {
            }
        }
    }

}

Мозг начинает закипать.

Максим Кобыляков

Уровень 41

10 января 2019, 13:37

У меня все эти нити в отдельных файлах

--------

Уровень 40

Master

10 января 2019, 13:27

Наследование ты делаешь, а почему interrupt вызываешь не унаследованный?

Ильнар

Уровень 20

10 января 2019, 13:59

К сожалению не очень понимаю разницу. Thread.currentThread() - возвращает же текущий поток? тот в котором мы сейчас находимся, верно? Попробовал на this.interrupt() заменить, но ситуация та же. Правда, возможно, я Вас неправильно понял.

Leo Bender

Уровень 18

11 января 2019, 17:17

Если создать поток 4 в main, только сделать тип fourthThread, а не Thread, чтобы был доступен метод showWarning(). Сделать старт потока, и вызвать метод showWarning(), и добавить в него вывод System.out.println(Thread.currentThread()); вернет вам Thread[main,5,main] сие означает, что мы методом Thread.currentThread() возвращаем поток main, так как и метод вызван в потоке main, а не наш созданный 4 поток. поэтому в методе нужно чётко указать, что мы хотим именно наш поток this.interrupt(); если в showWarning() сделать System.out.println(this); то вернет что нам нужно Thread[Thread-4,1,main]

public static class Thread_4 extends Thread implements Message {

        public Thread_4() {
            this.setPriority(MIN_PRIORITY);
        }

        @Override
        public void run() {
            while (!isInterrupted()) {
            }
        }

        @Override
        public void showWarning() {
            this.interrupt();
        }
    }

Ильнар

Уровень 20

11 января 2019, 21:25

С Thread.currentThread() вы правы, действительно так, спасибо большое. но у меня и с this это всё упорно не работает. видоизменил всё следующим образом и увидев вывод на консоль совсем перестал понимать что происходит. код:

public class Solution {
    public static List<Thread> threads = new ArrayList<>(5);
    public static fourthThread f = null;

    static {
        threads.add(new Thread(new firstThread()));
        threads.add(new Thread(new secondThread()));
        threads.add(new Thread(new thirdThread()));
        f = new fourthThread();
        threads.add(new Thread(f));
        threads.add(new Thread(new fifthThread()));
    }

    public static void main(String[] args) {
        for (Thread t : threads) {
            t.start();
        }
        f.showWarning();
    }

public static class fourthThread extends Thread implements Message {

        public fourthThread(){
            this.setPriority(MIN_PRIORITY);
        }

        @Override
        public void showWarning() {
            System.out.println(this.isInterrupted());
            System.out.println(this);
            this.interrupt();
            System.out.println(this.isInterrupted());
        }

        @Override
        public void run() {
            while (!isInterrupted()) {
            }
        }
    }

выдаёт: false Thread[Thread-3,1,main] false Как такое возможно? я похоже вообще перестаю понимать что происходит. При этом, с помощью приведения типа

((fourthThread) threads.get(3)).showWarning();

Я не могу вызвать метод showWarning, выходит ошибка каста. где-то я в другом месте тупанул что ли..

Leo Bender

Уровень 18

13 января 2019, 18:11

((fourthThread) threads.get(3)).showWarning();

и не кастанете, нельзя уточнять типы, от потомка к предку можно приводить тип. Thread f = new fourthThread(); так можно fourthThread f = new Thread, а так нельзя, в типе Fread нет методов и полей, которые есть в типе fourthThread.

f = new fourthThread();
threads.add(new Thread(f));

зачем так делать, оно из-за этого не работает правильно, у вас уже fourthThread типа Thread, а получается оно будет работать через интерфейс Runneble, в этом интерфейсе нет методов класса Thread, и вызов этих методов из созданной нити работать не будет.

f = new fourthThread();
threads.add(f);

Поправьте знающие точно, если я неправ. так тоже не работает с threads.add(new Thread(f));

threads.get(3)).interrupt();

вы можете проверить всё это сами, просто уберите наследование от Thread и сделайте поддержку интерфейса Runnable. когда мы сделали так threads.add(new Thread(f)); и вызываем interrupt() в нити, то в

public void interrupt() {
     if (this != Thread.currentThread())   будет FALSE
            checkAccess(); // дальше пытается взять System.getSecurityManager(); возвращает null

    synchronized (blockerLock) {
            Interruptible b = blocker;                // Тоже blocker == null
            if (b != null) {
// поэтому сюда не заходит
                interrupt0();           // Just to set the interrupt flag
                b.interrupt(this);
                return;
            }
        }
interrupt0();
}

Leo Bender

Уровень 18

13 января 2019, 18:55

но вот если сделать

@Override
        public void run() {
            while (!isInterrupted()) {
                try {
                    Thread.sleep(100);
                } catch (InterruptedException e) {
                    break;  }
            }
            System.out.println("Interrupted");
        }

threads.get(3)).interrupt();

то всё сработает. Делаем вывод, что для нитей через интерфейс Runneble исключения работают, но воспользоваться переменной isInterrupted нельзя.

Ильнар

Уровень 20

14 января 2019, 10:51

Огромная благодарность за потраченное время. Действительно, если работаем с наследниками класса Thread, то конструкция должна быть такой:

threads.add(new Thread(new thirdThread()));
threads.add(new fourthThread());

, где thirdThread - просто реализует интерфейс Runnable, а fourthThread наследник класса Thread. В этом случае уже и каст

((fourthThread)threads.get(3)).showWarning();

срабатывает и сама конструкция получается рабочей. То есть метод showWarning для класса fourthThread в этой задаче

@Override
       public void showWarning() {
           System.out.println(this.isInterrupted());
           this.interrupt();
           System.out.println(this.isInterrupted());
       }

Выдает false true Уф, кажется хоть что-то здесь стало проясняться. Ещё раз спасибо за потраченное время.

Den Nonamed

Уровень 20

1 апреля 2019, 17:45

ничего не понял(

hidden #1989002

Уровень 17

19 апреля 2019, 18:02

Спасибо, Leo, именно то, что я искал!