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

Question

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

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

"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)
  }

其中delay是< code > def delay()= thread . sleep(4000)，而< code>sync同步未来(调用< code>Await.ready(future，Duration。Inf))。这就是我要确保f0已经完成，f1在f0之后完成的方式。f0完成还不够，因为< code>firstSucc可能会改变未来。因此，f1应延迟到检查< code>f.get之后。

另一个想法是从promise中创造未来，并在某个时间点完成它们:

  "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服务：使用Executor Service控制任务执行顺序

Answer 1

对于大多数简单的情况，我认为一个单线程执行器就足够了——如果你一个接一个地开始你的未来，它们将被连续执行，并以同样的顺序完成。

但看起来你的问题实际上比你描述的更复杂：你不仅在寻找一种方法来确保一个未来比另一个晚完成，而且在一般情况下，使一系列任意事件按特定顺序发生。例如，您问题中的代码片段验证了第二个未来在第一个未来完成后开始（顺便说一句，我不知道在这种情况下，延迟是为了什么）。

您可以使用最终等待特定事件发生，然后再继续：

   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