scala – 如何撰写“期货”清单？

发布时间：2020-12-16 18:41:44 所属栏目：安全来源：网络整理

导读：我有一系列的Promises.我一直在寻找一种有效的方法来组成由此产生的期货.目前我发现组合它们最干净的方法是使用 scalaz Monoid,如下所示： val promises = List(Promise[Unit],Promise[Unit],Promise[Unit]) promises.map(_.future).reduce(_ |+| _).onSucce

我有一系列的Promises.我一直在寻找一种有效的方法来组成由此产生的期货.目前我发现组合它们最干净的方法是使用 scalaz Monoid,如下所示：

val promises = List(Promise[Unit],Promise[Unit],Promise[Unit])

  promises.map(_.future).reduce(_ |+| _).onSuccess {
    case a => println(a)
  }  

  promises.foreach(_.success(()))

有没有一个干净的方法来做这个不需要scalaz？

集合中的未来数量会有所不同,许多中间集合是不可取的.

解决方法

你可以使用Future.traverse：

import scala.concurrent.ExecutionContext.Implicits.global
import scala.concurrent.{ Future,Promise }

val promises = List(Promise[Unit],Promise[Unit])
Future.traverse(promises)(_.future)

这将为您提供未来[List [Unit]],它不完全符合“大量中间集合”的资格,但也不一定是理想的. Future.reduce也有效：

Future.reduce(promises.map(_.future))((_,_) => ())

这将返回在满足所有期货时将满足的期货[单位].

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!