scala - cats/fs2 相当于 ScheduledExecutorService.scheduleWithFixedDelay 是什么

Question

我找到了fs2-cron但它与调用具有固定延迟间隔的任务不同。如果 cats/fs2 中提供此功能，您能否提供代码示例。我确实看过猫计时器，但不知道如何以间隔重复该任务。

一种方法如下，但我认为添加 Thread.sleep 不是正确的方法。

Stream.eval(IO {
  println("BEING RUN!!");
  Thread.sleep(5000)
})
  .repeat
  .compile
  .drain
  .as(ExitCode.Success)

谢谢 萨阿德。

Answer 1

使用 Thread.sleep 并不是引入延迟的最佳方法，因为它会阻塞线程 5 秒。

通常，更好的替代方案是使用 IO.sleep，它不会阻塞线程，只是在给定的时间段内“挂起”任务，然后再次重新安排它。

Stream.eval(
  for {
    _ <- IO(println("BEING RUN!!"))
    _ <- IO.sleep(5.seconds)
  } yield ()
).repeat
  .compile
  .drain
  .as(ExitCode.Success)

更好的是，您可以使用 fs2 内置函数 awakeEvery 以固定间隔从流中发出单个元素，然后对流的每个元素执行效果.

Stream.awakeEvery[IO](5.seconds)
    .evalMap(_ => IO(println("BEING RUN!!")))
    .compile
    .drain
    .as(ExitCode.Success)