一个接一个地连续执行Scala Futures

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

导读：给定一个像这样返回Future的方法…… def myMethod(name: String,count: Int,default: Boolean): Future[Unit] = { ...} …我需要调用它N次,所以我已经定义了一个包含要传递的参数的元组列表： val paramList = List( ("text1",22,true),("text2",55,("text3

给定一个像这样返回Future的方法……

def myMethod(name: String,count: Int,default: Boolean): Future[Unit] = {
  ...
}

…我需要调用它N次,所以我已经定义了一个包含要传递的参数的元组列表：

val paramList = List(
  ("text1",22,true),("text2",55,("text3",77,false)
)

如何使用Future.traverse调用myMethod？

Future.traverse(paramList)(myMethod _).tupled(/* how do I pass the current tuple here? */)

解决方法

两种可能的方法：

val futuresFromSequence: Future[List[Unit]] = Future.sequence(paramList.map { 
  case (a,b,c) => myMethod(a,c) 
})

val futuresFromTraverse: Future[List[Unit]] = Future.traverse(paramList)(x => x match {
  case(a,c)
})

请注意,遍历将一些集合和一个函数从该集合的项目转移到将来的序列,而是获取一个未来列表并将其折叠到列表的未来.

如果你想坚持使用tupled语法(我个人不喜欢)：

Future.traverse(paramList)(x => (myMethod _).tupled(x))

如评论中所述,您可能希望以串行方式运行它们(尽管问题并非100％明确),在这种情况下,您可以使用foldLeft和flatMap来链接将来的执行：

myList.foldLeft(Future(List.empty[Unit]))((prevFuture,currentTuple) => {
  for {
    prev <- prevFuture
    curr <- (myMethod _).tupled(currentTuple)
  } yield prev :+ curr
})

基本上第一个生成器在启动累加器之前等待将来完成,这也会返回Future [List [Unit]].

（编辑：李大同）

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