1

我必须同时执行大约 10 到 15 个查询。在这些查询相互依赖的情况下，我已将这些查询放在一起。否则，每个查询我都有一个未来。现在我只想在执行所有查询时从包含未来的函数中得到一个指示成功或失败的响应。

val f1 = future{SQL("insert into user_general_info (user_id, userFName, userLName, displayAs)" +
  "values(" + userId + ",'" + form.fname + "','" + form.lname + "','1')").executeInsert();
}

val f2 = future {
  SQL("insert into personal('" + userId + "',1,1,0,0,1,'ALL',0,'E')").executeInsert();
}

/*
and so on...upto about f1 to f14 futures...
*/

现在我所做的是：

val job = for {
  a1 <- f1
  a2 <- f2
  a3 <- f3
  a4 <- f4
  a5 <- f5
  a6 <- f6
  a7 <- f7
  a8 <- f8
  a9 <- f9
  a10 <- f10
  a11 <- f11
  a12 <- f12
  a13 <- f13
  a14 <- f14
} yield ()

var res: Boolean = false

job.onSuccess {
  case result => res = true
}

if(res)
  List((1, userId, username)) //1 means success
else
  List((-2, userId, username)) //-2 means failure

问题是所有查询都没有运行，并且响应List((-2,userId,username))是基于变量 res 发送的。但是List((1,userId,username))应该在所有期货完成后返回。帮助...

4

1 回答 1

6

您可以使用Futures.sequence在单个未来中转换期货列表。

来自撰写期货的代码示例：

// oddActor returns odd numbers sequentially from 1 as a List[Future[Int]]
val listOfFutures = List.fill(100)(akka.pattern.ask(oddActor, GetNext).mapTo[Int])

// now we have a Future[List[Int]]
val futureList = Future.sequence(listOfFutures)

// Find the sum of the odd numbers
val oddSum = futureList.map(_.sum)
oddSum foreach println

在旁注中，我建议返回一个Option来表示成功或失败，例如

if(res) Some(List(userId, userName))
else None
于 2013-10-10T14:40:25.023 回答