scala – 永不完成的未来

发布时间：2020-12-16 08:52:15 所属栏目：安全来源：网络整理

导读：需要测试一些可能导致超时的方法,我想为此创建一个辅助函数.它应该返回一个永远不会完成的Future： def neverCompletes[T]: Future[T] = { ... } 但我想知道,我怎么能这样做？我可能喜欢以下内容： def neverCompletes[T]: Future[T] = { val p = Promise[T]

需要测试一些可能导致超时的方法,我想为此创建一个辅助函数.它应该返回一个永远不会完成的Future：

def neverCompletes[T]: Future[T] = { ... }

但我想知道,我怎么能这样做？我可能喜欢以下内容：

def neverCompletes[T]: Future[T] = {
  val p = Promise[T]()
  future {
    while(true) { }
  } onComplete {
    case x => 
      p complete x // needed?
      println("something went wrong!!!") // something is wrong...
  }

  p.future
}

但应该有更好的方法来实现这一目标.我也不确定是否需要完整的x //？那里需要.

解决方法

更新：

在Scala 2.12中,将有一个方法Future.never返回一个永远不会完成的未来.

简单的事情.只需创建一个Promise并返回它的Future而不用完成它：

def neverCompletes[T]: Future[T] = Promise[T].future

（编辑：李大同）

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