单元测试异步scala代码

Question

在试验并发执行时，我想知道如何实际测试它。执行流程具有副作用性质，创建未来是为了包装独立的执行/处理。

我一直在寻找一些关于如何正确单元测试的好例子，下面的场景（foo和bar是我希望测试的方法）：

情景#1

def foo : Unit = {
    Future { doSomething }
    Future { doSomethingElse }
}

private def doSomething : Unit = serviceCall1
private def doSomethingElse : Unit = serviceCall2

情景动机

foo立即返回，但调用两个执行单独任务的未来（例如，保存分析并将记录存储到数据库）。这些服务调用可以被模拟，但我试图测试的是，一旦我将它们包装在Futures中，这两个服务都会被调用

场景#2

def bar : Unit = {
    val futureX = doAsyncX
    val futureY = doAsyncY
    for {
        x <- futureX
        y <- futureY
    } yield {
        noOp(x, y)
    }
}

情景动机

从可以同时执行的长时间运行的计算开始（例如，获取总访客数，并获取网站上经常使用的用户代理标题）。将结果合并到其他一些操作中（在本例中，它是只抛出值的Unit方法）

注意：我熟悉参与者和测试参与者，但考虑到上面的代码，我想知道什么应该是最合适的方法（包括重构）

编辑我现在正在做的事情

implicit value context = ExecutionContext.fromExecutor(testExecutor)

def testExecutor = {
    new Executor {
        def execute(runnable : Runnable) = runnable.run
    }
}

这个执行上下文实现不会将Future作为一个单独的线程运行，整个执行将按顺序完成。这有点像黑客攻击，但基于电子和尚的回答，似乎其他解决方案更相似。

Answer 1

ScalaTest 3. x支持异步非阻塞测试。

Answer 2

如果您使用的是ScalaTest，请查看：http://doc.scalatest.org/2.0/index.html#org.scalatest.concurrent.Futures

Specs2还支持测试未来：http://etorreborre.github.io/specs2/guide/org.specs2.guide.Matchers.html

Answer 3

一种解决方案是使用确定性执行器。这不是一个简单的解决方案，但应该是一个技巧。