微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

斯卡拉等待期货顺序

我希望如下的代码将等待两个期货,但不会.

object fiddle {
  val f1 = Future {
    throw new Throwable("baaa") // emulating a future that bumped into an exception
  }

  val f2 = Future {
    Thread.sleep(3000L) // emulating a future that takes a bit longer to complete
    2
  }

  val lf = List(f1,f2) // in the general case,this would be a dynamically sized list

  val seq = Future.sequence(lf) 

  seq.onComplete {
    _ => lf.foreach(f => println(f.isCompleted))
  }
}

val a = FuturesSequence

我假设seq.onComplete将等待他们完成之前完成自己,但不是这样;它导致:

true
false

顺序在scala.concurrent.Future的源头上有点难以追随,我不知道我将如何实现一个等待所有原始期货(动态大小)序列的并行,或者这里可能是什么问题.

编辑:相关问题:https://worldbuilding.stackexchange.com/questions/12348/how-do-you-prove-youre-from-the-future

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐