并行通量与项目反应器中的通量

Question

因此，我从文档中了解到，并行通量本质上是将通量元素划分为单独的轨道。（本质上类似于分组）。就线程而言，这将是调度程序的工作。让我们考虑一下这样的情况。所有这些都将在通过runOn（）方法提供的同一个调度程序实例上运行。让我们考虑如下情况：

Mono<Response> = webClientCallAPi(..) //function returning Mono from webclient call

现在让我们打大约100个电话

Flux.range(0,100).subscribeOn(Schedulers.boundedElastic()).flatMap(i -> webClientCallApi(i)).collecttoList() // or subscribe somehow

如果我们使用parailFlux：

Flux.range(0,100).parallel().runOn(Schedulers.boundedElastic()).flatMap(i -> webClientCallApi(i)).sequential().collecttoList();

因此，如果我的理解是正确的，那么它似乎非常相似。那么，平行磁通相对于磁通的优势是什么？什么时候应该使用平行磁通相对于磁通？

Answer 1

实际上，您可能很少需要使用平行通量，包括在本例中。

在您的示例中，您正在触发100个Web服务调用。请记住，执行此操作所需的实际工作非常少——您生成并触发一个异步请求，然后一段时间后您会收到回复。在该请求之间

如果你把这个流量分开并并行运行，你是说你想把这些少量的CPU资源分开，这样它们就可以在不同的CPU核上同时运行。这绝对没有意义——分解流量、并行运行流量，然后稍后将其合并的开销将远远大于让它在正常的顺序调度程序上执行。

另一方面，假设我有一个Flux

（另外，作为结束语，您几乎总是希望使用具有并行流量的调度程序。parallel（），而不是调度程序。BoundedElistic（））