超时-- Scala.js的未来

Question

我需要在跨平台JVM / JS应用程序中对未来进行超时。这个超时只在测试中使用，所以阻塞解决方案不会那么糟糕。

我实现了以下代码段，以便在JVM上实现未来的超时：

  def runWithTimeout[T](timeoutMillis: Int)(f: => Future[T]) : Future[T] =
      Await.ready(f, Duration.create(timeoutMillis, java.util.concurrent.TimeUnit.MILLISECONDS))

这不适用于Scala.js，因为它没有Await的实现。还有其他解决方案可以在Scala.js和Scala中为未来添加超时吗？

Answer 1

您的代码并没有真正为现有的未来添加超时。这不可能。你所做的就是在那个特定的时刻设置一个等待未来的超时。这样，您就可以以另一种完全异步的方式进行复制，方法是创建一个未来

如果在给定的timeout

• otherwise内完成TimeoutException

解析为失败的TimeoutException，则

• 解析为f

import scala.concurrent._
import scala.concurrent.duration.Duration

import scala.scalajs.js

def timeoutFuture[T](f: Future[T], timeout: Duration)(
    implicit ec: ExecutionContext): Future[T] = {
  val p = Promise[T]()
  val timeoutHandle = js.timers.setTimeout(timeout) {
    p.tryFailure(new TimeoutException)
  }
  f.onComplete { result =>
    p.tryComplete(result)
    clearTimeout(timeoutHandle)
  }
  p.future
}

以上是为Scala.js编写的。您可以为JVM编写一个等价的程序，并将它们放入依赖于平台的源中。

或者，您也可以编写类似于java.util.Timer的东西，这在JVM和JS上都是支持的。