通过枚举引用字段更新对象时遇到Java并发问题

问题现象 #

• 多线程环境下，通过UpdatePolicy枚举调用Car#start方法更新对象字段时，字段会被设置为错误值
• 直接调用Car#start方法时，字段更新完全正常
• 移除State枚举后，并发问题彻底消失，初步定位是枚举的字段级变量存在线程不安全问题

问题根源 #

Java枚举本身是单例实现，默认具备线程安全性，但如果枚举中持有可变的实例字段（比如Car对象引用），且在多线程场景下对这些字段进行无同步的读写操作，就会触发数据竞争：

1. State枚举作为单例，所有线程共享同一个枚举实例，其持有的Car引用会被多个线程同时访问修改
2. 通过UpdatePolicy间接调用时，可能引入了共享引用的传递链路，加剧了并发竞争的概率
3. 直接调用Car#start时，大概率每个线程操作的是独立的Car实例，或者调用逻辑本身避开了共享资源的竞争

修复方案 #

针对这类枚举引发的并发问题，可采用以下几种修复思路：

• 剥离枚举的可变引用依赖：如果State枚举不需要持有Car实例，直接移除内部的Car引用字段，改为通过方法参数传递Car实例进行操作
• 给枚举的字段操作加同步锁：在枚举中涉及字段读写的方法上添加synchronized关键字，或者使用ReentrantLock保证操作的原子性
• 使用原子类管理引用：如果必须持有Car引用，将字段声明为AtomicReference<Car>，确保引用的读写操作是原子的
• 重构职责边界：让枚举只承担状态标识的职责，把对象状态更新的逻辑移到专门的服务类中，由服务类处理并发同步逻辑

代码修复示例 #

方案一：移除枚举内部的可变引用 #

enum State {
    RUNNING {
        @Override
        public void start(Car car) {
            car.setSpeed(100); // 直接操作传入的Car实例，避免共享引用
        }
    };

    public abstract void start(Car car);
}

// 调用逻辑
public void update(Car car) {
    State.RUNNING.start(car);
}

方案二：给枚举方法添加同步机制 #

enum State {
    RUNNING {
        @Override
        public synchronized void start() {
            this.car.setSpeed(100); // 同步方法保证单线程执行，避免数据竞争
        }
    };

    private Car car;

    public abstract void start();

    public void setCar(Car car) {
        this.car = car;
    }
}

内容的提问来源于stack exchange，提问作者kasapkiloet