@Scheduled and Spring webflux

Question

我正在寻找在响应式API中使用定时任务的方法。 我知道它使用线程池，因此与webflux组件不太兼容。

您有类似的解决方案吗？

- Saveriu CIANELLI

Answer 1

您可以在@Scheduled方法中尝试使用Schedulers.immediate()：

doWork()
  .subscribeOn(Schedulers.immediate())
  .subscribe()

作为结果，任务在提交它们的线程上运行。

- jreznot

Answer 2

有几种方法可以实现。考虑你想如何安排时间表，你也可以使用以下方式。

@Configuration
class ApplicationConfiguration() {

    @PostConstruct
    fun init() {

        Flux.interval(Duration.ofMinutes(12))
            .onBackpressureDrop()
            .flatMap { /* some task that return Mono<T> */ }
            .subscribeOn(Schedulers.boundedElastic())
            .subscribe()
    }
}

请注意，除非调用是阻塞的，否则不需要使用subscribeOn(Schedulers.boundedElastic())。另外，我正在使用onBackpressureDrop，但您的要求可能与此不同。

- nicholasnet

Answer 3

Webflux有自己的调度器，我猜应该是这样做：

Disposable schedulePeriodically(Runnable task, long initialDelay, long period, TimeUnit unit);  

- user13360561