Java同步问题

Question

我刚刚开始学习 Java 并发性，并且从以下代码中得到一些奇怪的输出：

ThreadSafe.java:

public class ThreadSafe {
    private int value;

    public ThreadSafe() {
        value = 0;
    }

    public synchronized int getNext() {
        if (value >= 10000) {
            value = 0;
        }
        return value++;
    }
}

RunnableImpl.java:

public class RunnableImpl implements Runnable {
    private String name;
    private ThreadSafe ts;

    public RunnableImpl(String name, ThreadSafe ts) {
        this.name = name;
        this.ts = ts;
    }

    @Override
    public void run() {
        while (true) {
            System.out.println(name + ": " + ts.getNext());
        }
    }
}

Main.java:

public class Main {
    public static void main(String[] args) {
        ThreadSafe ts = new ThreadSafe();

        Runnable a = new RunnableImpl("A", ts);
        Runnable b = new RunnableImpl("B", ts);

        new Thread(a).start();
        new Thread(b).start();
    }
}

每当线程关闭时，我都会得到如下输出：

B: 7320
B: 7321
A: 4278 // What?
A: 7323
A: 7324

Going back up the A 和 B 关闭的输出：

A: 4275
A: 4276
A: 4277
B: 2279 // ROBBLE ROBBLE!
B: 4279
B: 4280

我可以看到 A 早些时候在 4277 处停止，并在跳过 7322 之前在 4278 处恢复，继续 7323。 value++ 和 ++value 都会发生这种情况。我的理解是，synchronized 会让每个线程的 getNext() 方法调用完成，然后再让任何其他线程执行该方法。

当我在 threadsafe.java 中使用 private volatile int value; 时，我得到类似于以下内容的输出：

A: 8511
A: 8512
A: 8513
B: 7022 // Meh.
B: 8514
B: 8515

这次没有跳过任何数字（来自 ++value code>，仍然跳过 value++），但输出似乎仍然在第一次使用缓存值。

我在这里忽略了什么？

Answer 1

您的 ThreadSafe 类没问题。发生这种情况很可能是因为线程调度。也就是说，在第一个示例中，线程“A”在从实例获取 4278 之后但在将其打印到终端之前被取消调度。

然后“B”运行了一段时间，获取了 7322 以内的所有值，并在取消调度之前打印了 7321 以内的所有值，此时“A”再次被调度，下一步是打印它拥有的值先前获取的值 (4278)，并继续使用 ThreadSafe 类中的下一个值 (7323)。

所以你的问题是，虽然获取数字是正确的线程安全的，但打印它们却不是。