使用 cats-effect 的计时器实现可取消的 setInterval

Question

这是我尝试过的，但在第一次睡眠结束后无法取消。

import cats.syntax.all._
import cats.effect._
import scala.concurrent.duration._
import scala.language.higherKinds
object Foo {
def setInterval[F[_]](duration: FiniteDuration)(
fa: F[Unit]
)(implicit F: ConcurrentEffect[F], T: Timer[F]): F[IO[Unit]] = {
def run: F[Unit] = {
T.sleep(duration) *>
F.liftIO(F.runAsync(F.suspend(run))(_ => IO.unit)) *> fa
}
F.liftIO(F.runCancelable(run)(_ => IO.unit))
}
}

如何实现真正的可取消setInterval？

Answer 1

在法比奥·拉贝拉的帮助下，我认识到

F.liftIO(F.runAsync(F.suspend(run))(_ => IO.unit)) *> fa

runAsync只是让下一个递归调用在后台运行并且不可取消，所以我不得不在后台进行fa，就像这样

F.liftIO(F.runAsync(fa)(_ => IO.unit)) *> F.suspend(run)