Spring Webflux/Reactor释放调用线程

Question

因此，我理解在胡德Spring WebFlux和Reactor使用netty for nio，现在我想释放调用线程以释放资源，以便处理更多的请求。下面是释放调用线程的简单代码吗？

@GetMapping("/foo")
public Mono<Void> bar() {

  someService.veryLongSyncOperation();

  return Mono.empty();
}

我没有将服务调用包装在Flux/Mono中，我只是想首先验证在服务完成其长时间工作时调用线程是否被释放。这足以实现调用线程释放吗？如果是的话，有没有办法测试？

我在想，框架看到了返回类型，这就足以让它知道它必须释放调用线程。

Answer 1

您可以使用.subscribeon(Schedulers.弹性())，正如《反应堆参考指南》中提到的

@GetMapping("/foo")
public Mono<Void> bar() {
    return Mono.fromCallable(() -> someService.veryLongSyncOperation())
            .subscribeOn(Schedulers.elastic())
            .then();
}

每个订阅都将发生在来自Schedulers.elastic（）的专用单线程worker上。

UPD:现在有schedulers.boundedelastic（）调度程序。我建议在默认情况下使用它。