JavaRush/Помощь по Java задачам/ПОЖАЛУЙСТА, ПОМОГИТЕ (но не по этой задаче)

38 уровень

ПОЖАЛУЙСТА, ПОМОГИТЕ (но не по этой задаче)

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

Решен

Всем привет! Я пока плохо понимаю нити, поэтому решил придумать сам себе задачу чтобы разобраться. Идея программы: • Создаем внешнюю нить OuterThread из которой вызываем 2 других нити – Egg и Chicken. • Потом OuterThread засыпает на 5 секунд, чтобы передать управление Egg и Chicken. • Egg и Chicken должны спорить между собой о том, кто появился раньше. Каждая нить должна высказывать об этом и потом засыпать на время случайный промежуток времени time. • После того как 5 секунд сна OuterThread истекли, OuterThread должна определить какая нить из двух - Egg или Chicken сейчас НЕ спит и признать ее победителем Проблема в том, что вызванная первой нить Egg монополизирует управление и не даже засыпая не хочет отдавать управление нити Chicken. Подскажите, пожалуйста, как исправить ошибку?

public class MyChickenEgg {

    public static void main(String[] args) {

        Egg egg = new Egg();
        Chicken chicken = new Chicken();

        OuterThread outer = new OuterThread(egg, chicken);
    }

    public static int time(){
        double proxy = Math.random();
        int time  = (int) Math.round(proxy*100);
        return time;
    }




    public static class OuterThread extends Thread{
        private Egg t1;
        private Chicken t2;

        OuterThread(Egg t1, Chicken t2){
            super();
            this.t1 = t1;
            this.t2 = t2;
            start();
        }

        public void run(){
            try{
                t1.run();
                t1.sleep(MyChickenEgg.time());
                t2.run();
                t2.sleep(MyChickenEgg.time());
                Thread.sleep(5000);

                if (t1.isAlive()){
                    System.out.println("Победила " + t1.name);
                    t1.interrupt();
                    t2.interrupt();
                }else{
                    System.out.println("Победила " + t2.name);
                    t1.interrupt();
                    t2.interrupt();
                }

            }catch (InterruptedException e){


                System.out.println("Нити кончились!");
            }
        }

    }





    public static class Egg extends Thread{
        private String name = "Яичко";
        private int Ttime = 0;

        private static boolean marker = false;
        @Override
        public void run() {
            try {
                while (!marker){
                    System.out.println("Раньше появилось яйцо!");
                    Ttime = MyChickenEgg.time();
                    sleep(Ttime);
                    System.out.println("Задержка на " + Ttime);

                }
            }catch (InterruptedException e){}
        }
    }


    public static class Chicken extends Thread{
        public String name = "Курочка";

        private static boolean marker = false;

        public void run() {
           try {
               while (!marker){
                   System.out.println("Раньше появилась курица!");
                   Thread.sleep(MyChickenEgg.time());
               }
           }catch (InterruptedException e){}
        }
    }

}

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

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

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

Сергей

Уровень 36

Expert

26 июля 2018, 14:15

вот в этой лекции, в самом начале, Иван на примерах разбирает чем отличается run от start

Сергей

Уровень 36

Expert

26 июля 2018, 14:08

Я тут сходу увидел только одну внешнюю нить относительно main, создание которой спорная тема, можно было все реализовать в текущем классе MyChickenEgg. Вызова двух других нитей нет, есть просто запуск их заданий в общей нити. Где запуск нитей методом start()?

Уровень 38

28 июля 2018, 15:50

Спасибо! Помогло, частично. Теперь в случайном порядке выводится "Раньше яйцо" и "Раньше курица". Проблема - как проверить какая нить до этого работала? Пробовал через - egg.isAlive() и chicken.isAlive(), но обе живы!!!! Сделал проверку if(egg.isAlive() && chicken.isAlive()){...} - и это условие выполнялось.

public class MyChickenEgg {
    public static void main(String[] args) {
        Egg egg = new Egg();
        Chicken chicken = new Chicken();
        try{
            egg.start();
            chicken.start();
            Thread.sleep(2000);
        }catch (InterruptedException e){}

        if (egg.isAlive())
// всегда побеждает яйцо, потому что оно стоит первым.
//если бы первым была проверка chicken.isAlive(), то победила бы курица
{
            System.out.println("Победила " + egg.name);
            egg.interrupt();
            chicken.interrupt();
        }else if(chicken.isAlive()){
            System.out.println("Победила " + chicken.name);
            egg.interrupt();
            chicken.interrupt();
        }
    }
    public static class Egg extends Thread{
        private String name = "Яичкоо";
        private static boolean marker = false;
        public void run() {
               try {
                   while (!marker){
                       System.out.println("Раньше яйцо");
                       sleep(MyChickenEgg.time()); }
               }catch (InterruptedException e){}
        }
    }
    public static class Chicken extends Thread{
        public String name = "Курочка";
        private static boolean marker = false;
        public void run() {
            try {
                while (!marker){
                    System.out.println("Раньше курица");
                    sleep(MyChickenEgg.time()); }
            }catch (InterruptedException e){}
        }
    }
    public static int time(){double proxy = Math.random(); int time  = (int) Math.round(proxy*1000); return time; }
}

Сергей

Уровень 36

Expert

28 июля 2018, 22:13

Вы вызываете метод egg.interrupt(); chicken.interrupt(); метод ничего не делает, ставит флаг, этот метод прервет поток только когда поток находится в sleep, Вы прерываете поток рендомно, т.е. этот метод может сработать когда поток не находится в sleep и исключение не выскочит и поток так и будет работать проверяйте while не с помощью маркер а на флаг isInterrupted() вот пример:

System.out.println(Thread.currentThread().isInterrupted());
        Thread.currentThread().interrupt();
        System.out.println(Thread.currentThread().isInterrupted());
        System.out.println("я еще жив");
//Вывод:
//false
//true
//я еще жив

Сергей

Уровень 36

Expert

28 июля 2018, 22:19

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

Сергей

Уровень 36

Expert

28 июля 2018, 22:24

Посмотрите что возвращает метод getState у потока, возможно это можно использовать.

Уровень 38

28 июля 2018, 23:01

" если используем потоки, то даже таймер с рендомом не нужен, и без него всегда будет разный вывод" - это я понимаю. Просто сама задумка была: - берем поток, он активирует 2 других потока и таймер (например засыпает на 5 секунд) - 2 активированных потока спорят в случайном порядке - активировавший их поток просыпается, смотрит кто был последним активным и объявляет его победителем. Хотя вроде все просто, но я до сих пор так и не понимаю, как это реализовать(((

Сергей

Уровень 36

Expert

28 июля 2018, 23:17

А зачем их прерывать тогда, используйте AtomicBoolean и пусть его потоки дергают, один в false другой в true, или AtomicInteger пишут 1 и 2. Они потокозащищенные, одновременно его изменить не смогут, а в main через 5 сек посмотреть, что получилось, вывести победителя.

Уровень 38

28 июля 2018, 23:20

С AtomicBoolean не знаком. ПОдскажите, а обладая только знаниями из 16 главы описанную мной конструкцию можно реализовать?

Уровень 38

28 июля 2018, 23:21

Самоцели прервать потоки нет. Есть цель узнать, какой из потоков был последним активным на момент активации таймера. Хотя, мне кажется логичным прервать гонку, когда стало известно, кто победитель

Сергей

Уровень 36

Expert

28 июля 2018, 23:28

Я не препод, не могу правильно объяснить, лучше искать ответы в разных источниках, потом приходит просветление. Я на 16 лвл тут так же терялся в догадках как контролировать потоки... Сейчас понимаю что их лучше никак не контролировать, нужно только знать где поток в начале и где он в конце выполнения будет. В будущих лекциях учат их немного контролировать с помощью синхронизаторов, чтобы в какие то моменты потоки ждали другие потоки. Самое главное научат синхронизировать потоки с помощью монитора. Но самое интересное в реальной жизни можно и не углубляться в это, а использовать синхронизированные коллекции и Атомики. Но основы полезно знать.

Сергей

Уровень 36

Expert

29 июля 2018, 00:20

public static AtomicBoolean flag = new AtomicBoolean(false);
public static void main(String[] args) {
    Thread egg = new Thread(new Runnable() {
        @Override
        public void run() {
            while (!Thread.currentThread().isInterrupted()) {
                flag.set(true);
                System.out.println("я яйцо - я был первый");
                try {
                    Thread.sleep((int) (Math.random() * 1000));
                } catch (InterruptedException e) {
                    break;
                }
            }
        }
    });
    Thread cock = new Thread(new Runnable() {
        @Override
        public void run() {
            while (!Thread.currentThread().isInterrupted()) {
                flag.set(false);
                System.out.println("я курица - я была первой");
                try {
                    Thread.sleep((int) (Math.random() * 1000));
                } catch (InterruptedException e) {
                    break;
                }
            }
        }
    });

    egg.start();
    cock.start();
    try {
        Thread.sleep(5000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }

    System.out.println(flag.get() ? "яйцо" : "курица");
    egg.interrupt();
    cock.interrupt();
}

Сергей

Уровень 36

Expert

29 июля 2018, 00:24

прерываем после получения победителя

Сергей

Уровень 36

Expert

29 июля 2018, 00:37

если поиграться с потоками и методом interrupt

System.out.println(Thread.currentThread().isInterrupted()); //false
Thread.currentThread().interrupt();
System.out.println(Thread.currentThread().isInterrupted()); //true
Thread.sleep(1); // выкинет исключение при попытке заснуть с установленным флагом
System.out.println(Thread.currentThread().isInterrupted());//эта строчка не выполнится

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

Уровень 38

29 июля 2018, 16:24

Сергей, спасибо за помощь.

Уровень 38

29 июля 2018, 18:38

Кажется, я добился того, чего хотел:

public class MyChickenEgg {
    public static boolean marker = false;
    public static boolean secondMarker = true;
    public static void main(String[] args) {
        Egg egg = new Egg(); Chicken chicken = new Chicken();
        try{
            egg.start(); chicken.start();
            Thread.sleep(1000); marker = true;
        }catch (InterruptedException e){}
    }

    public static class Egg extends Thread{
        private String name = "Яичкоо";
        public void run() {
               try {
                   while (!marker){ System.out.println("Раньше появилось яйцо!"); sleep(MyChickenEgg.time()); }
                   if(MyChickenEgg.secondMarker == true){
                       System.out.println("Победила " + name);
                       MyChickenEgg.secondMarker = false; interrupt();
                   }else if(MyChickenEgg.secondMarker == false){
                       System.out.println("Нити кончились!"); interrupt();
                   }
          }catch (InterruptedException e){}
        }
    }

    public static class Chicken extends Thread{
        public String name = "Курочка";
        public void run() {
            try {
                while (!marker){
                    System.out.println("Раньше появилась курица!");
                    sleep(MyChickenEgg.time());
                }
                if(MyChickenEgg.secondMarker == true){
                    System.out.println("Победила " + name);
                    MyChickenEgg.secondMarker = false;  interrupt();
                }else if(MyChickenEgg.secondMarker == false){
                    System.out.println("Нити кончились!"); interrupt();
                }
            }catch (InterruptedException e){}
        }
    }

    public static int time(){  double proxy = Math.random();   int time  = (int) Math.round(proxy*1000); return time;   }
}

Уровень 38

29 июля 2018, 18:39

Сергей, если вам интересно - решение выше. Оно оказалось очень детским и даже стыдно, что я ничего не придумал за 4 дня лучше. Но, лучше так чем никак. Спасибо за помощь!