java - Flux Reactor - 每小时的简单时间表

Question

如何使用 Reactor 而不是 java 的调度程序来获得相同的效果？

Executors.newSingleThreadScheduledExecutor()
         .scheduleAtFixedRate(() -> counter.set(0) , computeDelay(), computePeriod(), TimeUnit.MILLISECONDS)

我试过了

 Flux
    .interval(Duration.ofMillis(computeDelay()),  Duration.ofMinutes(RESET_PERIOD_MINUTES))
    .doOnNext( counter.set(0))
    .subscribe())

但它会产生不必要的 Long 值。我在 Flux API 中找到了一些调度程序，但在尝试创建一个时我得到了 Disposable 对象，然后我不知道应该如何处理它

Answer 1

您找到了这两个选项。 Flux.interval 可用于与其他运算符组合。它发出代表每个报价单的长整数，因为 Flux 必须发出东西

Scheduler.schedulePeriodically 是另一个选项，几乎等同于 ExecutorService.scheduleAtFixedRate，只是它返回 Disposable 而不是 Future of Void。 (在这两种情况下你都会用它来取消工作)