scala - IO monad 如何使 Scala 中的并发变得容易？

Question

我看这个video从6分35秒开始，它提到了这个图表:

据说 IO Monad 可以轻松处理并发。我对此感到困惑:它是如何工作的？两个for commination如何实现并发(d和f的计算)？

Answer 1

不，它不会启用并发

for 推导式只能帮助您省略几个括号和缩进。

您引用的代码，翻译为[flat]map严格等同于:

async.boundedQueue[Stuff](100).flatMap{ a => 
  val d = computeB(a).flatMap{
    b => computeD(b).map{ result =>
      result
    }
  }

  val f = computeC(a).flatMap{ c =>
    computeE(c).flatMap{ e =>
      computeF(e).map{ result =>
        result
      }
    }
  }

  d.merge(f).map(g => g)
}

看，它只能帮助你省略几个括号和缩进(笑话)

并发隐藏在flatMap和map

中

一旦您了解了 for 如何转换为 flatMap 和 map 后，您就可以在它们内部实现并发。

由于 map 以函数作为参数，这并不意味着该函数在 map 函数执行期间执行，您可以将该函数推迟到另一个线程或稍后运行它。这就是并发的实现方式。

以Promise和Future为例:

val future: Future = ```some promise```
val r: Future = for (v <- future) yield doSomething(v)
// or
val r: Future = future.map(v => doSomething(v))
r.wait

函数doSomething在Future.map函数执行期间不会被执行，而是在promise提交时被调用。

结论

如何使用for语法suger实现并发:

1. for 会被 scala 编译器转换成 flatMap 和 map
2. 编写 flatMap 和 map，您将从参数中获取回调函数
3. 随时随地调用您所拥有的功能

进一步阅读

许多语言的流程控制功能共享相同的属性，它们就像分隔延续shift/reset，它们将以下执行捕获到函数的范围内。

JavaScript:

async function() {
  ...
  val yielded = await new Promise((resolve) => shift(resolve))
                                  // resolve will captured execution of following statements upto end of the function.
  ...captured
}

haskell :

do {
  ...
  yielded_monad <- ```some monad``` -- shift function is >>= of the monad
  ...captured
}

斯卡拉:

for {
  ...
  yielded_monad <- ```some monad``` // shift function is flatMap/map of the monad
  ...captured
} yield ...

下次当您看到将后续执行捕获到函数中的语言功能时，您就知道可以使用该功能实现流程控制。

定界延续和 call/cc 之间的区别在于，call/cc 捕获程序的整个后续执行，但定界延续有一个范围。