在vertx web背压示例中，为什么删除observeOn会增加延迟？

Question

在vertx web backpressure示例中，假设我作为标准verticle启动服务器verticle，那么observeOn（RxHelper.scheduler（vertx.getDelegate（））会做什么。

我在一台8核机器上部署了8个事件循环线程和8个Server verticle实例，我没有在路由的处理程序中阻止IO调用

    server.requestStream()
      .toFlowable()
      .map(HttpServerRequest::pause)
      .onBackpressureDrop(req -> req.response().setStatusCode(503).end())
      .observeOn(RxHelper.scheduler(vertx.getDelegate())) // Why does removing this line increase CPU and latency?
      .subscribe(req -> {
        req.resume();
        router.accept(req);
      });

Answer 1

也许是因为你最终会使用默认的调度程序，它不使用vertx事件循环，而且由于使用java的正常线程模型，速度确实很慢。当然，除非您使用rxhelper的helper方法将rxjava的默认调度程序配置到事件循环和阻塞线程池。

RxJavaPlugins.setComputationSchedulerHandler(s -> RxHelper.scheduler(vertx));
RxJavaPlugins.setIoSchedulerHandler(s -> RxHelper.blockingScheduler(vertx));
RxJavaPlugins.setNewThreadSchedulerHandler(s -> RxHelper.scheduler(vertx));

文档：https://vertx.io/docs/vertx-rx/java2/#_scheduler_support