我可以使用AtomicReference来获取Mono的值，并且代码仍然保持反应性吗

Question

对不起，我对反应范式还不熟悉。可以使用AtomicReference来获取Mono的值，因为反应式代码可以异步运行，并且不同的事件可以在不同的线程上运行。请参见下面的示例。我也不确定这段代码是否被认为是被动的

示例代码：

public static void main(String[] a) {
  AtomicReference<UserDTO> dto = new AtomicReference<>();
  Mono.just(new UserDTO())
      .doOnNext(d -> d.setUserId(123L))
      .subscribe(d -> dto.set(d));
  UserDTO result = dto.get();
  dto.set(null);
  System.out.println(result); // produce UserDTO(userId=123)
  System.out.println(dto.get()); // produce null
}

Answer 1

您共享的代码段不能保证始终有效。无法保证doOnNext中的函数将在dto之前发生。get（）。您已经创建了比赛条件。

您可以运行以下代码来模拟这一点。

    AtomicReference<UserDTO> dto = new AtomicReference<>();
    Mono.just(new UserDTO())
            .delayElement(Duration.ofSeconds(1))
            .doOnNext(d -> d.setUserId(123L))
            .subscribe(dto::set);
    UserDTO result = dto.get();
    System.out.println(result); // produces null

要使此示例完全响应，您应该在订阅运算符中打印出来

Mono.just(new UserDTO())
        .doOnNext(d -> d.setUserId(123L))
        .subscribe(System.out::println)

在一个更“真实的世界”示例中，您的方法将返回一个Mono

**编辑**

如果您希望在反应流中进行阻塞调用，那么前面的堆栈溢出问题包含了一个很好的答案