小编And*_*ich的帖子

获取 webflux 事件循环调度程序

我将webfluxnettyjdbc一起使用,因此我用以下方式包装阻塞 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 事件循环调度程序?

project-reactor reactor-netty spring-webflux

4
推荐指数
1
解决办法
2605
查看次数