说明volatile：此代码是线程安全的吗？

Question

我试图volatile用一个例子来说明它的使用和重要性，如果volatile省略的话，它实际上不会给出很好的结果。

但我并不习惯使用volatile。下面的代码的想法是，如果volatile省略则导致无限循环，如果存在则是完全线程安全的volatile。以下代码是线程安全的吗？您是否还有其他使用的现实且简短的代码示例，如果没有该示例，volatile将会给出明显不正确的结果？

这是代码：

public class VolatileTest implements Runnable {

    private int count;
    private volatile boolean stopped;

    @Override
    public void run() {
        while (!stopped) {
            count++;
        }
        System.out.println("Count 1 = " + count);
    }

    public void stopCounting() {
        stopped = true;
    }

    public int getCount() {
        if (!stopped) {
            throw new IllegalStateException("not stopped yet.");
        }
        return count;
    }

    public static void main(String[] args) throws InterruptedException {
        VolatileTest vt = new VolatileTest();
        Thread t = new Thread(vt);
        t.start();
        Thread.sleep(1000L);
        vt.stopCounting();
        System.out.println("Count 2 = " + vt.getCount());
    }
}

Answer 1

Victor是对的，您的代码存在问题：原子性和可见性。

这是我的版本：

    private int count;
    private volatile boolean stop;
    private volatile boolean stopped;

    @Override
    public void run() {
        while (!stop) {
            count++; // the work
        }
        stopped = true;
        System.out.println("Count 1 = " + count);
    }

    public void stopCounting() {
        stop = true;
        while(!stopped)
           ; //busy wait; ok in this example
    }

    public int getCount() {
        if (!stopped) {
            throw new IllegalStateException("not stopped yet.");
        }
        return count;
    }

}

如果线程观察到stopped==true，则可以确保工作完成并且结果可见。

从易失性写入到易失性读取（在同一变量上）之间存在事前关系，因此如果有两个线程

   thread 1              thread 2

   action A
       |
 volatile write  
                  \
                     volatile read
                          |  
                       action B

动作A在动作B之前发生；B中可以看到A中的写入。