Try Future sequence

2024-06-16 07:46:07 浏览数 (2)

这两天重新看了点儿Erik Meijer讲Try和Future,自己对他所讲内容没有什么违和感了,蛮开心的。

1)关于OptionT, EitherE, R 和 TryT的使用场景。

这三种type很容易让人想到处理Exception的场景。这些types如果只是针对Exception就略显狭隘了。现在我的感觉是:

1)Option适于处理业务逻辑上需要空值的地方,这里不一定是因为Exception导致。往往是业务上需要表达这种“空”/“没值”。

2)Either的左值不一定是Exception,表示一个计算可能有两种结果比较好,右值按照惯例表示正确/正常路径下的结果。左值是另个分支的结果。当然,也可以放Exception,Error什么的。STTP的Response body部分就是一个EitherError, T。

3)Try,其实才是最适合表示一个计算可能出现Exception的type。Try的apply()接受的就是一个代码块并运行,对异常封装到子类Failure。

最后的感觉是Option,Either更像标量,是结果的一个静态表示。而Try是动态的,包含了代码的执行。看Try的定义体会下:

代码语言:scala复制
object Try {
  def apply[T](r: => T): Try[T] =
    try Success(r) catch {
      case NonFatal(e) => Failure(e)
    }
}

2)Future's sequence()的实现。

1)这是Erik喜欢的递归方式的实现。

其中两个flatMap都是Future上的flatMap。

代码语言:scala复制
def sequence[T](fts: List[Future[T]]): Future[List[T]] = {
  fts match {
    case Nil => Future(Nil)
    case ft::fts => ft.flatMap( t => sequence(fts).flatMap(ts => Future(t::ts)))
  }
}

2)通过类型推导,我发现把flatMap()换成了map()也符合类型检查,似乎也也没有大的问题。但在逻辑上,这个实现就是要要等着所有的future依次从尾部开始都complete了才能执行。而上面的实现整个过程都是异步的,更符合Future的原意。

代码语言:scala复制
def sequence[T](fts: List[Future[T]]): Future[List[T]] = {
  fts match {
    case Nil => Future(Nil)
    case ft::fts => ft.flatMap( t => sequence(fts).map(ts => t::ts))
  }
}

3)Erik通过async,await实现的sequence。

这种方式似乎更容易理解,但风格太不FP了。Erik警告说,如果是基于Future编程,那么不要wait。但是在async块里除外,因为async本身是异步的所以不会阻塞。另外,async/await在模块scala-async里,需要加到sbt的依赖里。

代码语言:scala复制
import scala.async.Async.{async, await}
def sequence[T](fs: List[Future[T]]): Future[List[T]] = async {
  var _fs = fs
  val result = ListBuffer[T]()
  while (_fs != Nil) {
    result  = await { _fs.head }
    _fs = _fs.tail
  }
  result.toList
}

4)还可以通过Promise来实现。

等磕完promise再说吧。。。

0 人点赞