Почему поток не останавливается?

Question

[pshevnin]

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

import java.util.Random;

class Vlakno extends Thread {
    private String name;
    boolean isRun;
    boolean isWait;

    public Vlakno(String name){
        this.name = name;
        isRun = true;
        isWait = false;
        start();

    }

    public void run() {
        int counter = 1;
        while (isRun){

            System.out.println(name + " - " + counter++);
        }
    }
}

public class ZK3 {
    public static void main(String[] args) throws InterruptedException {
        Vlakno liche = new Vlakno("liche");
        Vlakno sude = new Vlakno("sude");
        Random random = new Random();
        for (int i = 0; i < 10; i++) {

            int rnd = random.nextInt(10);
            if (rnd % 2 == 0){
                if (sude.isWait){
                    synchronized (sude){
                        sude.isWait = false;
                        sude.notify();
                    }
                }
                else{
                    synchronized (sude){
                        sude.isWait = true;
                        sude.wait();
                    }
                }

            }
            else{
                if (liche.isWait){
                    synchronized (liche){
                        liche.isWait = false;
                        liche.notify();
                    }
                }
                else{
                    synchronized (liche){
                        liche.isWait = true;
                        liche.wait();
                    }
                }

            }
        }
        synchronized (sude){
            sude.isRun = false;
        }
        synchronized (liche){
            liche.isRun = false;
        }
        
    }
}

Answer 1

[Vamp]

Тут есть две проблемы.

Первая очевидная проблема в том, что main поток на первой же итерации впадает в сон на методе wait(), а в программе больше нет потоков, которые могли бы вызвать notify() и разбудить main. Поэтому main бесконечно ждёт и не может остановить liche и sude.

Вторая совсем неочевидная в том, что синхронизация некорректно используется. У вас синхронизируется только запись в переменную isRun. Чтение этой переменной так же должно быть синхронизировано. Иначе это приведет к странным неуловимым багам.

Comments

[pshevnin]

Не подскажете, где правильно вызывать wait() так, чтобы засыпали потоки liche и sude? Спасибо

[Vamp]

pshevnin, чтобы засыпали liche и sude, то wait() нужно вызывать именно в них. То есть в методе run(). А в методе main убрать wait() и оставить только notify().

Answer 2

[Сергей Горностаев]

Потому что переменная isRun не волатильная и синхронизация в читающем потоке не выполняется, так что с его точки зрения переменная значения не меняла.