SpringReactorWebflux调度器并行性

Question

对于完全非阻塞的端到端反应调用，是否建议显式调用publishOn或subscribeOn来切换调度器？对于消耗cpu或不消耗cpu的任务，总是使用并行流量来优化性能是否有利？

Answer 1

对于完全非阻塞的端到端反应调用，是否建议显式调用publishOn或subscribeOn来切换调度器？

向下游发布数据时使用publishon，而从上游使用数据时使用subscribeon。所以这真的取决于你想做什么样的工作。

对于消耗cpu或不消耗cpu的任务，总是使用并行流量来优化性能是否有利？

Flux.range(1, 10)
        .parallel(4)
        .runOn(Schedulers.parallel())
        .sequential()
        .elapsed()
        .subscribe(i -> System.out.printf(" %s ", i));

上面的代码完全是浪费，因为i几乎会立即被处理。下面的代码将比上面的代码执行得更好：

Flux.range(1, 10)
        .elapsed()
        .subscribe(i -> System.out.printf(" %s ", i));

现在考虑一下：

public static <T> T someMethodThatBlocks(T i, int ms) {
    try { Thread.sleep( ms ); }
    catch (InterruptedException e) {}
    return i;
}

// some method here
Flux.range(1, 10)
        .parallel(4)
        .runOn(Schedulers.parallel())
        .map(i -> someMethodThatBlocks(i, 200))
        .sequential()
        .elapsed()
        .subscribe(i -> System.out.printf(" %s ", i));

输出类似于：

 [210,3]  [5,1]  [0,2]  [0,4]  [196,6]  [0,8]  [0,5]  [4,7]  [196,10]  [0,9]