Mono/Flux流内存顺序效应及多线程变量可见性问题咨询

你的调研结论大部分是正确的，这段代码不存在可见性问题，线程安全，以下是两个问题的具体解释：

1 第4行对inputArg的map赋值对第12行的可见性保证 #

不会出现NPE，在ARM、DEC等弱内存序平台下也不会出现竞态问题，核心有两层保证：

• Reactive Streams规范的底层内存同步机制：Reactor所有跨线程信号传递的实现中，都会在切换线程前后插入内存屏障（volatile读写、Java 9+ VarHandle的acquire/release语义），确保前序线程的所有写入对后续线程完全可见。第4行的赋值动作发生在flatMapMany接收上游onNext信号的阶段，早于内部flatMap异步流的所有执行逻辑，二者之间存在明确的happens-before关系，不管后续异步逻辑运行在哪个线程，都能读到正确赋值后的map实例。
• ConcurrentHashMap自身的内存语义保障：ConcurrentHashMap的所有写入操作都自带volatile级别的可见性保证，进一步兜底避免可见性问题。
  小修正：你之前对subscribeOn的理解存在偏差，subscribeOn只会影响订阅链最上游的订阅线程，不会强制整个父子流运行在同一线程，WebClient、Spring Data Redis的IO操作本身还是会切换到对应IO线程，但只要是Reactor内部管理的线程切换，都会自带内存屏障，不会破坏可见性。

2 第2行flatMapMany中的修改对第18行map算子的可见性机制 #

你的理解完全正确，核心机制有两点：

• 普通算子默认同步执行：Reactor中除了publishOn、subscribeOn、parallel等显式指定线程切换的算子外，绝大多数算子（包括map）的RunStyle都是SYNC，不会主动切换线程，同一个信号在上下游同步算子之间传递时天然共享同一个线程上下文，所有修改自然可见。
• 跨线程信号的happens-before保证：就算中间存在切换线程的算子，Reactor的信号传递机制依然会保证上游发射onNext的动作和下游接收onNext的动作之间存在happens-before关系，上游对输入参数的所有修改都能被下游算子感知。

补充建议 #

你当前的写法已经足够安全，如果要进一步降低后续维护风险，可以把InputArg的map初始化逻辑提前到流构造之前，避免后续修改流结构时破坏现有同步逻辑。

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