在使用 project reactor 时，不能在 `map` 中通过 `subscribe` 同步修改外部对象状态；应改用 `flatmap` + `collectlist` 等响应式操作符，将内部 `flux` 聚合后构造新对象，确保数据流完整性与线程安全性。
在响应式编程中，一个常见误区是试图在 map 操作内对 Flux 进行“手动订阅”（如 insideFlux.subscribe(...)），期望副作用（如调用 A.setVal(val)）能同步改变外部对象。但这是反模式：
- subscribe() 是终端操作，触发异步执行，无法保证执行时机与顺序；
- map 是纯函数式转换，要求无副作用、不可变输入输出；
- 多线程环境下，A 实例可能被多个订阅者并发访问，导致竞态或 null 值残留。
✅ 正确做法是：将内部 Flux 的数据完整聚合为确定性结构（如 List>，从而实现声明式、可组合的数据流编排。
以下为推荐实现方式：
Flux<A> outsideFlux = groupedFlux
.flatMap(element -> {
// 1. 获取内部 Flux（例如远程调用、数据库查询等）
Flux<Double> insideFlux = someOtherCallThatReturnsThisFluxOfDouble(element);
// 2. 收集所有 Double 值 → Mono<List<Double>>
return insideFlux.collectList()
// 3. 基于收集结果构造 A 实例（注意：A 应设计为不可变或构造时初始化）
.map(doubleList -> new A(doubleList));
});? 关键要点说明：
- ✅ 使用 flatMap：允许将每个上游元素映射为一个新的 Flux，并自动扁平化其结果；
- ✅ 使用 collectList()：将不定长的 Flux
转换为 Mono - >，提供确定性的聚合结果；
- ✅ 构造 A 时传入完整数据：避免状态污染，符合响应式编程的不可变原则；
- ⚠️ 若 A 必须可变且需复用实例，请确保线程安全（如使用 AtomicReference 或 synchronized），但强烈建议优先采用不可变设计。
补充示例（含完整类定义）：
static class A {
private final List<Double> values; // 不可变字段，构造即赋值
A(List<Double> values) {
this.values = Collections.unmodifiableList(new ArrayList<>(values));
}
public List<Double> getValues() { return values; }
}
// 使用示例
Flux<A> result = Flux.just(1, 2, 3)
.flatMap(i -> generateDoublesFor(i).collectList().map(A::new));
private static Flux<Double> generateDoublesFor(int input) {
return Flux.just((double) input * 100, (double) input * 200);
}总结：永远避免在 map/filter 等中间操作中调用 subscribe()；响应式流的“消费”应通过 flatMap + 聚合操作符（collectList, reduce, next 等）完成，并以新数据结构承载结果——这才是真正符合 Reactor 设计哲学的写法。
