0

以下方法同步调用serveThis()a的方法和单独线程中的方法,即异步: serviceserveThat()

public void doSomething() {
    service.serveThis();
    new Thread(() -> service.serveThat()).start();
}

我想在一个service.serveThat()将异步执行的单元测试中进行验证,因为根据规范它不能同步执行。所以,我想防止以后有人像这样删除开始一个新线程:

public void doSomething() {
    service.serveThis();
    // This synchronous execution must cause the test to fail
    service.serveThat();
}
4

3 回答 3

1

我想验证是否service.serveThat()会异步执行。

这将是。语法是这样说的。不要测试平台。

于 2017-10-31T10:12:23.907 回答
0

为了实现这一点,我使用 Mockito:

Thread threadServeThatRunsOn;

@Test
public void serveThatWillBeExecutedAsynchronously() throws Exception {
    doAnswer(invocation -> {
        threadServeThatRunsOn = Thread.currentThread();
        return null;
    }).when(mockService).serveThat();

    testObject.doSomething();

    verify(mockService, timeout(200)).serveThat();
    assertNotEquals(threadServeThatRunsOn, Thread.currentThread());
}

现在,如果有人修改doSomething()以便service.serveThat()同步运行,那么这个测试就会失败。

于 2017-10-31T10:06:24.453 回答
0

可以在代码中的任何位置获取Thread.currentThread(),因此您可以编写类似这样的内容并基于它进行断言(如果没有,您可以使用 Mockito 以不同的方式实现此目的YourInterface):

public class ThreadChecker implements YourInterface {

    volatile Thread serveThisThread;
    volatile Thread serveThatThread;

    public void serveThis() {
        serveThisThread = Thread.currentThread();
    }

    public void serveThat() {
        serveThatThread = Thread.currentThread();
    }
}

单元测试可以是这样的,但根据用例可能需要额外的断言:

ThreadChecker mockService = new ThreadChecker(); 

@Test
public void serveThatWillBeExecutedAsynchronously() throws Exception {
    doSomething();
    TestCase.assertFalse(mockService.serveThatThread == mockService.serveThisThread);
}
于 2017-10-31T10:40:40.017 回答