Мультипоточность, статичные переменные и synchronized

Решен

У меня вопрос к знатокам: может ли сложиться такая ситуация, что после проверки условия if(createdThreadCount < Solution.count) планировщик потоков остановит текущий поток и продолжит выполнение другого потока? То есть условие пройдется лишний раз и получится лишний 16й поток? И вообще насколько это правильно, проверять условия и выполнять последующий код (пусть даже и из одной строки)без synchronized в случае мультипоточности и одновременного использования и изменения статичных переменных (которые по сути одни на класс)?

public class Solution {
    static int count = 15;
    static  volatile int createdThreadCount;

    public  static void main(String[] args) {
        System.out.println(new GenerateThread());
    }

    public static class GenerateThread extends Thread {

        public  GenerateThread(){
            super(String.valueOf(++createdThreadCount));
            start();
        }
        @Override
        public  void run() {

                if (createdThreadCount < Solution.count) {
                    System.out.println(new GenerateThread());
                }

        }
        @Override
        public String toString() {
            return (getName()+" created");
        }
    }
}

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

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

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

Дмитрий

Уровень 25

23 ноября 2019, 21:51

Да, я тут что-то перечитал комментариев про while, и поэтому похоже в голове прокручивался именно такой код. Хотя непосредственно с решением задачи проблем не было. Затупил, что тут скажешь..)) Спасибо! Но тогда попробую задать аналогичных вопросов по задачам из того же раздела:

public static class OnlineGame extends Thread {
        public static volatile boolean isWinnerFound = false;

        public static List<String> steps = new ArrayList<String>();

        static {
            steps.add("Начало игры");
            steps.add("Сбор ресурсов");
            steps.add("Рост экономики");
            steps.add("Убийство врагов");
        }
        protected Gamer gamer1 = new Gamer("Ivanov", 3);
        protected Gamer gamer2 = new Gamer("Petrov", 1);
        protected Gamer gamer3 = new Gamer("Sidorov", 5);

        public void run() {
            gamer1.start();
            gamer2.start();
            gamer3.start();

            while (!isWinnerFound) {
            }
            gamer1.interrupt();
            gamer2.interrupt();
            gamer3.interrupt();
        }
    }
    public static class Gamer extends Thread {
        private int rating;

        public Gamer(String name, int rating) {
            super(name);
            this.rating = rating;
        }

        @Override
        public void run() {


            for (int i = 0; i < OnlineGame.steps.size(); i++) {
                try {
                    Thread.sleep(1000/rating);//Add your code here - добавь код тут
                } catch (InterruptedException e) {
                    System.out.println(getName()+":проиграл");break;}
                if (OnlineGame.isWinnerFound) break;
            System.out.println(getName()+":"+OnlineGame.steps.get(i));
            if (i==OnlineGame.steps.size()-1) {OnlineGame.isWinnerFound=true;
                System.out.println(getName()+":победитель!");break;}

            }}
    }

Дмитрий

Уровень 25

23 ноября 2019, 21:53

может ли в задаче выше, случится такое, что одна из нитей if (OnlineGame.isWinnerFound) проверку на false прошла, но остановилась на следующей строке кода, в то время, как другая нить изменит переменную isWinnerFound, и выведет таким образом победителя? При этом после того как победитель будет выявлен, напечатается System.out.println(getName()+":"+OnlineGame.steps.get(i));

IceBerg

Уровень 41

Master

23 ноября 2019, 21:58

решение

Вполне, более того код будет и дальше выполнятся, и если это последний шаг, то ты можешь получить ещё одного победителя.

Дмитрий

Уровень 25

23 ноября 2019, 22:04

Спасибо, тогда разобрался, во всяком случае на данном этапе)) В таком случае по-хорошему нужно в некоторых задачах править валидатор. В примере ниже например программа может после проверки if (reader.ready()) в одном из потоков застопориться на выполнении reader.readline и вызвать его лишний раз, что приведет к IOException и некорректному завершению.

public class Solution {
    public static volatile AtomicInteger readStringCount = new AtomicInteger(0);
    public static volatile BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
    public static void main(String[] args) throws IOException {

        int count = Integer.parseInt(reader.readLine());

        ReaderThread consolReader1 = new ReaderThread();
        ReaderThread consolReader2 = new ReaderThread();
        ReaderThread consolReader3 = new ReaderThread();

        consolReader1.start();
        consolReader2.start();
        consolReader3.start();

        while (count > readStringCount.get()) {
        }

        consolReader1.interrupt();
        consolReader2.interrupt();
        consolReader3.interrupt();
        System.out.println("#1:" + consolReader1);
        System.out.println("#2:" + consolReader2);
        System.out.println("#3:" + consolReader3);

        reader.close();
    }

    public static class ReaderThread extends Thread {
        private List<String> result = new ArrayList<String>();

        public void run() {


                while(!isInterrupted()){
                try {
                    if (reader.ready()) {result.add(reader.readLine());
                    readStringCount.incrementAndGet();}
                    } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            //add your code here - добавьте код тут
        }

        @Override
        public String toString() {
            return result.toString();
        }
    }

IceBerg

Уровень 41

Master

23 ноября 2019, 22:17

решение

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

Дмитрий

Уровень 25

23 ноября 2019, 22:24

Так и подумал. Большое спасибо!

Justinian Judge в Mega City One

Master

23 ноября 2019, 21:40

решение

Присоединяюсь к Айсбергу, в коде мы видим рекурсивную матрешку, одна нить запускает вторую, вторая третью, и тд. Как она лишний раз пройдется? Конструктор вызвался, статическая переменная изменилась, в методе ран условие выполняется один раз. Если будет создано 15 нитей, условие не выполнится. Относительно, синхронайзд и изменения статических переменных..Мультипоточность одна из самых сложных тем, наверное даже самая сложная тема всего джава кора, поскольку она непосредственно затрагивает огромное количество низкоуровневых тем, тут только копни что происходит в том или ином случае, сразу выходишь на JVM, memory model, оптимизации JVM, вплоть до регистров процессора. Чтобы разобраться что к чему, помимо соответствующих задач, лекций и обязательно комментариев к лекциям/Обсуждений задач, материалов по ссылкам с комментариев, надо писать свои примерчики, разбирать самые простейшие моменты, как они работают, много читать Stack overflow, Головача по мультипоточности или другие видео, статьи, кодить примерчики, разбирать момент за моментом, книги. Только тогда понимание и придет. В какой-то мере :)

IceBerg

Уровень 41

Master

23 ноября 2019, 21:27

полезный

"То есть условие пройдется лишний раз и получится лишний 16й поток" - пройдётся лишний раз где? У нас же каждая нить не может создать больше одной нити. А вот если заменить if на while, тогда другой вопрос, и вероятность такой ситуации будет весьма высока.