Java并发-synchronized方法不起作用

Question

好吧，我现在正在与 java 并发作斗争，我有同步问题。我在堆栈上读了很多问题，但这里什么也看不到。

Class Checker 检查X 类的值。它应该始终是偶数(2,4,6,8 ...)

类 X 包含由 Checker.class 检查的值。 X提供了increment方法，该方法应将X.class的value加2

类Y它只负责调用X.class的inc()方法

import java.io.IOException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

/**
 * Checks for concurrency fails
 * 
 * @author Jones
 * 
 */
class Checker implements Runnable {

    public Checker() {
        new Thread(this).start();
    }

    @Override
    public void run() {
        while (true) {
            if (X.value % 2 != 0){
                System.out.println("Concurrency fail");
                System.out.println(X.value);
            }

            try {
                TimeUnit.MILLISECONDS.sleep(1);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

class X {
    static Integer value = 0;

    static synchronized void inc() {
        value++;
        Thread.yield(); // to accelerate probability of non concurrent
                        // behaviour
        value++;
    }
}

class Y implements Runnable {

    X x;

    public Y(X x) {
        this.x = x;
        new Thread(this).start();
    }

    @Override
    public void run() {
        while (true) {

            x.inc();
            try {
                TimeUnit.MILLISECONDS.sleep(150);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

}

public class Main {

    public static void main(String[] args) throws IOException {

        X x = new X();

        for (int i = 0; i < 5; i++) {
            new Y(x);
        }

        new Checker();

    }
}

我不明白为什么这里的并发失败。这应该是正确的。 所有 Y 线程都在同一个对象上操作，这意味着它们应该使用相同的锁？为什么这里并发失败呢？我错过了什么？

Answer 1

您正在直接访问 X.value，无需任何同步。因此，您不能对它的值(value)抱有任何期望。

引入一个同步的 getValue() 方法，并从 Checker 中调用此方法，以获得您期望的行为。