主页 / 问题 / 823008
Accepted
Oleg
Asked:2020-05-04 14:44:47 +0000 UTC2020-05-04 14:44:47 +0000 UTC

斯卡拉。未来在后卫

  • 772

有没有办法在守卫内等待未来的执行？
不在case块内或块外Try：

import scala.util.Try
import scala.concurrent.Future
import scala.concurrent.ExecutionContext.Implicits.global

object Main extends App {
  val f = Future {
    Thread.sleep(999999)
    true
  }

  Try (1) match {
    case x if f => println("Waited for future")  // Here
    case _ => println(":(")
  }
}

感谢您的关注

scala

1 个回答

  1. Best Answer

    有办法，但自己等待未来是一种反模式。他在这里：

    import scala.concurrent.duration._
import scala.concurrent.Await
import scala.language.postfixOps

Try (1) match {
  case x if Await.result(f, 10 hours) => println("Waited for future")  // Here
  case _ => println(":(")
}

    请注意，由于Thread.sleep(999999).

    这是一种更犹太的方式：

    f.foreach { resultOfF =>
  Try(1) match {
    case x if resultOfF => println("Waited for future") // Here
    case _ => println(":(")
  }
}

    只有在你的例子中，我会ExecutionContext用我自己的替换默认的。因为默认的不等待未来的结果。

    import java.util.concurrent.Executors

import scala.concurrent.{ExecutionContext, Future}
import scala.util.Try

object Main extends App {
  val ex = Executors.newCachedThreadPool()
  implicit val exec: ExecutionContext = ExecutionContext.fromExecutor(Executors.newCachedThreadPool())

  val f = Future {
    Thread.sleep(10000)
    true
  }

  f.map { resultOfF =>
    Try(1) match {
      case x if resultOfF => println("Waited for future") // Here
      case _ => println(":(")
    }
  }.onComplete(_ => ex.shutdown())
}
    • 1

相关问题