1

猫效应有什么作用IO.suspend,为什么有用?有文档,但并不完全清楚。

文档提供了以下用例:

import cats.effect.IO

def fib(n: Int, a: Long, b: Long): IO[Long] =
  IO.suspend {
    if (n > 0)
      fib(n - 1, b, a + b)
    else
      IO.pure(a)
  }

例如,我为什么要使用上面的,而不是下面的类似功能?

import cats.effect.IO

import scala.annotation.tailrec

@tailrec
def fib(n: Int, a: Long, b: Long): IO[Long] =
  if (n > 0)
    fib(n -1, b, a + b)
  else
    IO.pure(a)

4

1 回答 1

2

其中一个是懒惰的,另一个是渴望的。

def printFibIfNeeded(n: Int, shouldPrint: Boolean) = {
  val fibResult = fib(n, 0, 1)
  if (shouldPrint) fibResult.map(r => println(r))
  else IO.unit
}

如果您使用suspend, thenfibResult将只是一个计算方法,如果shouldPrint. = false.

在您的第二个示例中,您已经计算了值并使用 IO 将其包装,因此即使最终没有必要,您也可以让计算机运行 CPU。

对于纯计算,它可能看起来像是一种优化,但如果你在那里有副作用怎么办?

def dropAllUsersInDB: Future[Unit]

def eagerDrop = IO.fromFuture(IO.pure(dropAllUsersInDB))

def lazyDrop = IO.fromFuture(IO.suspend(IO.pure(dropAllUsersInDB)))

第一个示例创建Future了将删除所有用户的内容 - 因此无论我们是否将此 IO 组合到我们的程序中,用户都将被删除。

第二个示例suspend在 IO 配方中的某个位置,因此Future除非将评估 IO,否则不会创建它。所以用户是安全的,除非我们明确地将这个 IO 组合成将成为计算一部分的东西。

在您的示例中,如果您这样做,这将变得更加明显:

def fib(n: Int, a: Long, b: Long): IO[Long] =
  IO.suspend {
    println("evaluating")
    if (n > 0)
      fib(n - 1, b, a + b)
    else
      IO.pure(a)
  }

@tailrec
def fib(n: Int, a: Long, b: Long): IO[Long] = {
  println("evaluating")
  if (n > 0)
    fib(n -1, b, a + b)
  else
    IO.pure(a)
}

然后调用fib创建一个 IO 值而不对其进行评估,您将看到不同之处。

于 2020-12-31T13:13:29.600 回答