1

考虑以下单元测试示例:

class MySpec extends AsyncFlatSpec {

  "this" should "fail after some timeout" in {
    val resultFuture: Future[_] = Promise().future
    
    for (result <- resultFuture) yield {
      assert(result == ???) // some assertions
      assert(result == ???) // some assertions
      assert(result == ???) // some assertions
    }
  }
}

问题

如果resultFuture 永远不会完成,那么测试套件也永远不会完成。据我了解,这是由于SerialExecutionContext实施方式所致。

问题

有没有什么“好”的方法可以为这种测试设置超时,这样如果未来没有完成,测试就会失败,而不是永远阻塞整个测试套件?


更新和澄清

虽然解决方案https://stackoverflow.com/a/65746143/96766https://stackoverflow.com/a/65749840/96766(由 @matthias-berndt 和 @tomer-shetah 发布)适用于线程阻塞的情况,这不是我要找的。

让我对这个问题做一个重要的澄清。在我的情况下,未来最终不会完成,但永远不会完成。例如,当 aFuture是从Promise从未解析的(没有人调用它success也没有人调用failure它)中获得时。在这种情况下,建议的解决方案仍然会无限阻塞。

有没有一种方法可以解决这个问题,AsyncSpec而无需使用真正的基于池的执行上下文和Await-ing 未来?

4

3 回答 3

3

使用eventuallyscalatest

  1. 延伸Eventually
  2. 使用以下代码设置检查的超时和间隔
 import scala.concurrent.duration._
 eventually(timeout(1 minutes), interval(5 seconds)) {
    resultFuture.futureValue shouldBe ???
}
于 2021-01-15T12:46:40.467 回答
0

您可以使用 trait TimeLimits。例如,您可以有一个测试类:

class MySpec extends AsyncFlatSpec with TimeLimits {

  "this" should "fail" in {
    failAfter(2.seconds) {
      val resultFuture: Future[_] = Future {
        Thread.sleep(3000)
      }

      assert(true)
    }
  }

  "this" should "pass" in {
    failAfter(2.seconds) {
      val resultFuture: Future[_] = Future {
        Thread.sleep(1000)
      }

      assert(true)
    }
  }
}
于 2021-01-16T12:48:56.620 回答
0

使用AsyncTimeLimitedTests特质。

https://www.scalatest.org/scaladoc/3.2.0/org/scalatest/concurrent/AsyncTimeLimitedTests.html

于 2021-01-16T03:15:41.600 回答