scala - 如何在 Scalatest 中为异步套件设置超时？

Question

考虑以下单元测试示例：

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/96766和https://stackoverflow.com/a/65749840/96766（由 @matthias-berndt 和 @tomer-shetah 发布）适用于线程阻塞的情况，这不是我要找的。

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

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

Answer 1

使用eventually自scalatest

1. 延伸Eventually
2. 使用以下代码设置检查的超时和间隔

 import scala.concurrent.duration._
 eventually(timeout(1 minutes), interval(5 seconds)) {
    resultFuture.futureValue shouldBe ???
}

Answer 2

您可以使用 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)
    }
  }
}

Answer 3

使用AsyncTimeLimitedTests特质。

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