scala – IO Monad中未来的行为

2023年2月27日 140次阅读

我编写了一个返回IO值的函数：

def foo(x : Int): IO[Future[Int]] = IO {
  // do some IO
  }

我正在使用Scalaz的IO类型类.

然后,我将其用于表达式,如下所示：

  (for {
    _ <- foo(10)
  } yield bar()).unsafePerformIO()

由于调用foo的结果是Future,这个Future将在一个单独的线程中执行并且yield,会立即调用bar(),还是在调用bar()之前,yield会等到Future完成？

更新：

我运行了以下实验,看起来它不会瞬间产生：

def foo() : IO[Future[Unit]] = IO { Future.successful(bar()) }

def bar() : Unit = {
  Thread.sleep(200000);
  println("done")
}

scala> (for {
     | _ <- foo()
     | } yield "bar").unsafePerformIO()
res3: String = bar

有没有办法异步处理这个未来？

最佳答案

IO { Future.successful(bar()) }

将执行bar(),用Success或Failure包装它并将结果放入IO.

另一方面

IO { Future { bar() } } // or IO { Future(bar()) }

将通过隐式ExecutorContext将bar()执行委托给单独的线程.

Future(value：=> T)是一个异步调用,你正在寻找,而Future.successful(value：=> T)是同步的,应该只用于立即返回已计算的值.

点赞