Início / coding / Perguntas / 79317852
Accepted
user79074
Asked: 2024-12-30 22:20:54 +0800 CST

Como executar um futuro imediatamente

  • 772

Digamos que eu tenha um futuro definido da seguinte forma

val fut = Future {
  println("Doing some work")
  Thread.sleep(5000)
  println("Work done")
}

Estou acessando este futuro mais tarde, mas gostaria que ele fosse executado na inicialização em vez de quando eu referenciasse o futuro.

Li em algum lugar que isso pode ser executado imediatamente fazendo:

scala.concurrent.ExecutionContext.Implicits.global.execute(fut)

No entanto, isso não será compilado, pois execute só pega um Runnable. Existe uma maneira de executar esse future imediatamente em um thread diferente?

scala

1 respostas

  1. Best Answer

    Os Scala Futurecriados usando Future.applysão executados com entusiasmo.

    Para execução não rápida, você terá que definir sua própria classe para criar indiretamente Futureusando Promise.

    import scala.concurrent.{Future, Promise}
import scala.util.{Failure, Success, Try}

    class NonEagerFuture[A](computation: => A) extends Runnable {
  private val promise = Promise[A]

  override def run(): Unit = {
    Try(computation) match {
      case Success(result)    => promise.success(result)
      case Failure(exception) => promise.failure(exception)
    }
  }

  def isFutureCompleted(): Boolean =
    promise.isCompleted

  def getResult(): A =
    if (!promise.isCompleted) {
      throw new IllegalStateException("Future is not completed yet")
    } else {
      promise.future.value.get.get
    }

  def getScalaFuture(): Future[A] =
    promise.future

}

    Pode ser usado da seguinte forma:

    println("creating the future")

val nonEagerFuture = new NonEagerFuture({
  println("Doing some work")
  Thread.sleep(5000)
  println("Work done")
  println("returning 5 as result")
  5
})

println("running for the future")
scala.concurrent.ExecutionContext.Implicits.global.execute(nonEagerFuture)

// can also get the internal scala future and use it
// this scala future will not have the eager problem 
println("get the scala future") 
val scalaFuture = nonEagerFuture.getScalaFuture()
println("printing scalaFuture" + scalaFuture)

// or block for completion using isFutureCompleted
println("checking for the future")
while (!nonEagerFuture.isFutureCompleted()) {
  Thread.sleep(1000)
  println("Checking completed: " + nonEagerFuture.isFutureCompleted())
}

println("getting result for the future")
println("Result: " + nonEagerFuture.getResult())
    • 1

relate perguntas