在 Akka 中等待函数完成或 5 秒后超时

Question

我正在尝试等待函数在 5 秒后完成或超时，但无论我做什么，我都无法阻止以下异常。有趣的是它被父actor捕获：

java.util.concurrent.TimeoutException: Futures timed out after [5 seconds]

我尝试过的解决方案之一（来自this 问题）：

val f = Future { dockerClient.execStartCmd(execCreateCmdResponse.getId()).exec() }
val result: Try[InputStream] = Await.ready(f, 5.seconds).value.get

val resultEither = result match {
  case Success(t) => log.info("right")
  case Failure(e) => log.info("left")
}

Answer 1

确实可以使用 akka ask 模式来实现这一点。但是有一个不同的解决方案可以在没有 akka 的情况下使用。

将您的阻塞 Await 代码包装到另一个 Future 并注册 onComplete 函数

import concurrent.ExecutionContext.Implicits.global
import scala.concurrent.duration._
import scala.concurrent.{Await, Future}
import scala.util.{Failure, Success, Try}

val sleepTimeout = 1*1000

val f = Future( Thread.sleep(sleepTimeout); Try(10))
val timeoutFuture = Future(Await.result(f, 5.seconds))
timeoutFuture.onComplete {
  case Success(Success(t))  => println(t)
  case Success(Failure(ex))  => println("error on Try" + ex.getMessage)
  case Failure(e) => println("timeout " + e.getMessage)
}

解释匹配案例

• Success(Success(t)) 首先Success 是timeoutFuture，表示它没有超时。第二个Success 是Try - 表示没有抛出异常。
• Success(Failure(ex)) 与第一个相同，但Try 内有异常
• Failure(e) 这是处理超时的地方。