用同步块替换 volatile 不起作用

Question

我正在学习 this 教程。我了解 volatile 关键字的用法。但是当我试图在不使用 volatile 关键字并在同步块中对关注变量进行操作的情况下获得相同的结果时，它不起作用。它抛出 IllegalMonitorStateException。这是我试过的修改后的代码。

public class VolatileTest {
private static Integer MY_INT = 0;

public static void main(String[] args) {
    new ChangeListener().start();
    new ChangeMaker().start();
}

static class ChangeListener extends Thread {
    @Override
    public void run() {
         synchronized(MY_INT){
        int local_value = MY_INT;
        while ( local_value < 5){
            if( local_value!= MY_INT){
                System.out.format("Got Change for MY_INT : {0}", MY_INT);
                 local_value= MY_INT; 
                  try {
                MY_INT.wait();
            } catch (Exception e) { e.printStackTrace(); }}
            }
        }
    }
}

static class ChangeMaker extends Thread{
    @Override
    public void run() {
         synchronized(MY_INT){
        int local_value = MY_INT;
        while (MY_INT <5){
            System.out.format("Incrementing MY_INT to {0}", local_value+1);
            MY_INT = ++local_value;
            try {
                MY_INT.notify();
            } catch (Exception e) { e.printStackTrace(); }
        }
    }
}}}

我想知道的是，在这种情况下，volatile 可以用 synchronized 块替换，如果是，那么该怎么做？谢谢

Answer 1

问题出在这里：

 MY_INT = ++local_value;

MY_INT 是一个 Integer 变量，当你给它赋一个新值时，你在这里锁定的对象：

 synchronized(MY_INT){

将与您在此处通知的对象不同：

  MY_INT.notify();

...这将导致异常。

解决方法是制作锁对象static final。显然这意味着你不能分配给它......但这就是重点！

用同步块替换 volatile 不起作用

Replacing volatile with synchronized block is not working

java

multithreading

thread-safety