Flowable.parallel对Flowable.flatMap？

Question

RxJava 2.0.5引入了ParallelFlowable类型，对应于Flowable.parallel()操作符。我发现实现并行性的一般建议是使用flatMap，如下所示：

Flowable.just(1,2,3)
    .flatMap(x -> Flowable.just(x)
        .observeOn(Schedulers.computation())
        .map(y -> y + 1))
    .forEach(System.out::println);

什么时候使用flatMap来并行比较合适，什么时候使用ParallelFlowable更好？

Answer 1

我发现实现并行性的一般建议是使用flatMap，如下所示：

这些建议来自于parallel的引入之前，所以从那时起就应该考虑API的演变。

什么时候使用flatMap进行并行比较合适，什么时候使用ParallelFlowable更好？

ParallelFlowable有一组有限的操作符：map、filter、doOnNext、reduce、flatMap等，而不是完全成熟的Flowable API。因此，如果您有一些“异国情调”并行的事情不能用上面的操作符表示，那么您应该坚持基于Flowable.flatMap的并行(或者考虑groupBy并行)。

否则，这里是并行化方法(代码)之间的基准比较。