主页 / user-7229131

Snuii's questions

Martin Hope
Snuii
Asked: 2024-10-04 15:55:05 +0800 CST
  • 6

我之前将实体保存到表中，如下所示：
insertTableOne(foo).then(insertTableTwo(foo)).then(Mono.just(foo));

团队成员建议使用以下方法.and()来并行化插入件：
insertTableOne(foo).and(insertTableTwo(foo).thenRetuen(foo);

虽然我同意它看起来更简洁，但我找不到任何文档表明使用.and()将同时执行Schedulers.parallel()两个插入。我认为它仍然是连续的，除非明确说明与并行。

我错了吗？

spring-webflux
Martin Hope
Snuii
Asked: 2024-08-08 19:40:30 +0800 CST
  • 5

我目前正在编写一个方法，该方法需要在继续下游操作之前将每个元素添加到并发HashMap中。例如

public Flux<Bar> methodOne(final Flux<Foo> foos) {
    Map<UUID, Foo> idToFoo = new ConcurrentHashMap<>();
    return foos.doOnNext(foo -> idToFoo.put(foo.getId(), foo)
         .flatMap(foo -> fooToBar(foo, idToFoo));
}

我是否可以确定fooToBar()传递的地图中将填充相应的元素？

据我所知，doOnNext()它是同步的，它会在继续下游之前执行并完成 lambda。然而，我遭到了一位高级开发人员的反对 - 他们认为这是一种副作用，是一种“发射后不管”的类型。

我正在努力更好地理解源代码，以便能够证明用例的合理性，但也想在这里检查。

谢谢

spring-webflux