rx-java - Flowable.parallel vs Flowable.flatMap？

Question

RxJava 2.0.5 引入了 ParallelFlowable类型，对应Flowable.parallel()运算符(operator)。我发现实现并行性的一般建议是使用 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

I've found that the general advice for achieving parallelism is with flatMap like so:

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

When is it appropriate to use flatMap for parallelism, and when is it better to use ParallelFlowable?

ParallelFlowable有一组有限的运算符: map , filter , doOnNext , reduce , flatMap等，而不是完整的 Flowable API。因此，如果您有一些“异国情调”的并行操作无法用上述运算符表达，您应该坚持使用 Flowable.flatMap。基于并行性(或考虑 groupBy 并行性)。

否则， here是并行化方法 ( code) 之间的基准比较。