如何在 Scala 单元测试中指定异步调用的确切执行顺序？

Question

我已经为 Scala 中的 futures 编写了许多不同的单元测试。 所有异步调用都使用执行上下文。 为了确保异步调用始终以相同的顺序执行，我需要延迟一些相当困难的任务并减慢测试速度。 执行者可能仍然（取决于它的实现）在其他任务之前完成一些任务。

测试具有特定执行顺序的并发代码的最佳方法是什么？例如，我有以下测试用例：

"firstSucc" should "complete the final future with the first one" in {
    val executor = getExecutor
    val util = getUtil
    val f0 = util.async(executor, () => 10)
    f0.sync
    val f1 = util.async(executor, () => { delay(); 11 })
    val f = f0.firstSucc(f1)
    f.get should be(10)
  }

其中延迟为def delay() = Thread.sleep(4000) 和sync 同步未来（调用Await.ready(future, Duration.Inf)）。 这就是我想确保 f0 已经完成并且 f1 在 f0 之后完成的方式。完成 f0 是不够的，因为 firstSucc 可能正在洗牌期货。因此，f1应该延迟到f.get检查之后。

另一个想法是从承诺创建期货并在某个时间点完成它们：

  "firstSucc" should "complete the final future with the first one" in {
    val executor = getExecutor
    val util = getUtil
    val f0 = util.async(executor, () => 10)
    val p = getPromise
    val f1 = p.future
    val f = f0.firstSucc(f1)
    f.get should be(10)
    p.trySuccess(11)
  }

有没有更简单/更好的方法来定义执行顺序？也许是另一种可以配置提交任务顺序的执行服务？ 对于这种特定情况，将第二个未来延迟到检查结果之后可能就足够了，但在某些情况下，所有未来都必须按特定顺序完成。

完整的代码可以在这里找到：https://github.com/tdauth/scala-futures-promises

测试用例属于此类：https://github.com/tdauth/scala-futures-promises/blob/master/src/test/scala/tdauth/futuresandpromises/AbstractFutureTest.scala

这个问题可能是相关的，因为 Scala 可以使用 Java Executor Services：Controlling Task execution order with ExecutorService

Answer 1

对于大多数简单的情况，我想说一个单线程执行器就足够了 - 如果您一个接一个地启动您的期货，它们将按顺序执行，并以相同的顺序完成。

但看起来您的问题实际上比您所描述的更复杂：您不仅在寻找一种方法来确保一个未来完成晚于另一个，而且总的来说，一系列任意事件以特定顺序发生。例如，您问题中的 sn-p 验证第二个未来 starts 在第一个 completes 之后（我不知道 delay 的用途是什么顺便说一句）。

您可以使用eventually 等待特定事件发生后再继续：

   val f = Future(doSomething) 
   eventually { 
      someFlag shouldBe true
   }
   val f1 = Future(doSomethingElse) 
   eventually { 
      f.isCompleted shouldBe true
   }
   someFlag = false   
   eventually { 
      someFlag shouldBe true
   }

   f1.futureValue shoudlBe false