我将webflux与netty和jdbc一起使用,因此我用以下方式包装阻塞 jdbc 操作:
static <T> Mono<T> fromOne(Callable<T> blockingOperation) {
return Mono.fromCallable(blockingOperation)
.subscribeOn(jdbcScheduler)
.publishOn(Schedulers.parallel());
}
Run Code Online (Sandbox Code Playgroud)
阻塞操作将由jdbcScheduler处理,我希望其他管道将由webflux event-loop Scheduler处理。
如何获取 webflux 事件循环调度程序?