此代码不是线程安全的吗？

du369 发表于 Dev

du369

我期望这段代码是线程安全的。我运行了几次，但是得到了不同的结果。但是，如果我取消注释该sleep(1000)零件，则每次都会打印10000（至少从我的测试运行结果中得出）。

那怎么了可能与这有关thread.join()吗？

public class Test implements Runnable{

    private int x;

    public synchronized void run(){
            x++;
    }

    public static void main(String args[]){
        Test test = new Test();
        Thread thread = null;
        for (int i = 0; i < 10000; i++) {
            thread = new Thread(test);
            try {
                thread.join();
            } catch (InterruptedException e) {}
            thread.start();
        }
//        try {
//          Thread.sleep(1000);
//      } catch (InterruptedException e) {
//          e.printStackTrace();
//      }
        System.out.println(test.x);
    }
}

编辑：哎呀，我不好。我误解了Thread＃join的功能。与run()方法同步是一个坏主意。

内森·休斯（Nathan Hughes）

这里有两个问题：

一种竞争状态，其中主线程在所有辅助线程之前完成。
内存可见性问题，其中不能保证主线程看到x的更新值。

Thread＃join是使用Object＃wait实现的。使用的条件变量是线程上的alive标志：

groovy:000> new Thread().isAlive()
===> false

Thread.join在线程启动之前检查alive标志，因此isAlive返回false，join在线程启动之前返回。计数器最终仍会增加，但是由于该线程未发生联接，因此主线程可能在所有线程可以执行之前就打印出x的结果。

添加睡眠会使所有线程有足够的时间完成x，这就是主线程将其打印出来之前所期望的x。

除了竞争条件外，还有一个内存可见性问题，因为主线程正在直接访问x并且未使用与其他线程相同的锁。您应该使用synchronized关键字将访问器添加到Runnable中：

public class Test implements Runnable{

    private int x;

    public synchronized void run(){
        x++;
    }

    public synchronized int getX() {
        return x;
    }

并更改使用访问器的主要方法：