разобраться с volatile

[datgen]

Добрый вечер.
Нашел такой пример и в нем действительно без volatile потоки не останавливаются

public class VolatileDemo {
    // вначале попробуйте без volatile
     volatile private boolean btExit = false;
     volatile private boolean isRunning = true;

    // задача для интерфейсного потока
    Runnable gui = new Runnable() {

        @Override
        public void run() {
            int k=-1;
            while (isRunning) {
                try {
                    k = System.in.read() ;
                    btExit = k>=0;
                    System.out.println("gui input: "+k);
                } catch (Exception e) {
                }
            }
            System.out.println("gui thread finished");
        }
    };

    // задача для игрового потока
    Runnable game = new Runnable() {

        @Override
        public void run() {
            int k=1;
            while (!btExit) {
                k+=k;
                k%=100;
                // System.out.print("");
            }
            isRunning=false;
            System.out.println("game thread finished");
        }
    };

    // запуск потоков
    public void start() {
        new Thread(gui).start();
        new Thread(game).start();
    }


    // чтобы остановить программу запущенную без volatile и без System.out.print(""); в игровом цикле
    // в Eclipse в окне консоли кликните на красный квадрат
    public static void main(String[] args) {
        new VolatileDemo().start();
    }
}

я написал такой пример, проясните кто нибудь почему тут без volatile все работает

class Task2{

    private boolean b = false;

    Runnable runnable1 = new Runnable() {
        @Override
        public void run() {
            while (!b) {
                try {
                    System.out.println("+");
                    Thread.sleep(100);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    };

    Runnable runnable2 = new Runnable() {
        @Override
        public void run() {
            try {
                Thread.sleep(500);
                b = true;
            } catch (InterruptedException e) {
            }
        }
    };

    public void start() {
        new Thread(runnable1).start();
        new Thread(runnable2).start();
    }
}

[p51x]

Потому что тут есть запись и компилятор это заметил, и не стал кэшировать.

[alexzk]

Thread.sleep(500);

скорее всего, но все равно там ничего не гарантиравано без volatile. Что-то измените и все сломается.
Кросс-потоковое общение должно быть обязательно синхронизировано неким способом (там их несколько), в яве 1 из них volatile.

Вообще, отстутствие явной верной сихронизации м-у потоками так и проявляется - случайно что-то не так. Например, на 1 процессоре все ок, на 4 процессорах - все сломалось не понять как. Т.е. как только полезло "не понять что", начинаем проверять все между-поточные передачи данных и делать их верно синхронными.

[datgen]

Сообщение от p51x

Потому что тут есть запись и компилятор это заметил, и не стал кэшировать.

можно тут чуть подробнее пожалуйста

[Пепел Феникса]

Кросс-потоковое общение должно быть обязательно синхронизировано неким способом (там их несколько), в яве 1 из них volatile.

я бы не назвал volatile синхронизацией.
volatile говорит компилятору что значение может изменится в ином потоке, он отключает кеширование результата обращения.

[alexzk]

Сообщение от Пепел Феникса

я бы не назвал volatile синхронизацией.
volatile говорит компилятору что значение может изменится в ином потоке, он отключает кеширование результата обращения.

Это скорее вы про С++ говорите
http://alenacpp.blogspot.com/2006/04/volatile.html
где ничего как раз не гарантируется - т.е. просто не оптимизируем и все.

А вот в яве
https://ru.stackoverflow.com/questio...le-%D0%B2-java

это уже атомарная операция.

Но лично я всегда делал так:

private final AtomicBoolean isSome = new AtomicBoolean(false);

[Пепел Феникса]

главное это пункт 2 ответа, а не 1.

без этого модификатора, компилятор/JIT может оптимизировать чтение, это и в Java мире так же.
атомарность уже отличается, да(в С++ не гарантируется к примеру)