以不同步的方式改变对象的两个不同部分不安全吗？

Question

假设我有一个相对简单的对象，具有两个属性：

@Data
public class MyObject {
    public Integer a;
    public Integer b;
}

我可以安全地在某个线程中改变 a 并在其他线程中安全地改变 b 吗？例如，这段代码不会受到竞争条件的影响吗？

public MyObject compute() {
    MyObject newObj = new MyObject();
    List<Runnable> tasks = new ArrayList<>();
    Runnable computeATask = () -> {
        Integer a = computeA();
        newObj.setA(a);
    };
    Runnable computeBTask = () -> {
        Integer b = computeB();
        newObj.setB(b);
    };
    tasks.add(computeATask);
    tasks.add(computeBTask);
    tasks.stream().parallel().forEach(Runnable::run);
    return newObj;
}

Answer 1

这是在 JLS，§17.6 中指定的。单词撕裂：

Java 虚拟机实现的一个考虑因素是每个字段和数组元素都被认为是不同的；对一个字段或元素的更新不得与任何其他字段或元素的读取或更新交互。

因此，在您的示例中，a 可能由与 b 不同的线程编写，这一事实不会产生任何数据争用。

但它仍然需要一个线程安全的机制来读取结果。在您的示例中，并行流保证启动线程可以在 forEach 返回后安全地读取两个变量。

您的示例可以简化为

public MyObject compute() {
    MyObject newObj = new MyObject();
    Stream.<Runnable>of(() -> newObj.setA(computeA()), () -> newObj.setB(computeB()))
        .parallel().forEach(Runnable::run);
    return newObj;
}

但推荐的模式是首先执行计算，然后构造对象，然后可以将其设计为不可变对象。

public class MyObject {
  public final Integer a, b;

  public MyObject(Integer a, Integer b) {
      this.a = a;
      this.b = b;
  }
}

public MyObject compute() {
    return CompletableFuture.supplyAsync(() -> computeA())
      .thenCombine(CompletableFuture.supplyAsync(() -> computeB()), MyObject::new)
      .join();
}

这样，您就可以确保看到 MyObject 的任何线程都将看到一致的字段值，无论其余应用程序中发生什么情况。