JUnit/Mockito：在新线程中抛出异常

Question

我正在为以下Java代码编写单元测试：

try {
    new Thread(() -> myService.myMethod()).start();
    return new MyResponse("Done");
} catch (Exception exception) {
    throw new MyException("Internal Error", exception);
}

我试图模拟myService抛出错误的过程。myMethod（），以便在上面代码的catch块中提取它，并抛出MyException实例。

在我的JUnit测试中（使用org.springframework.test.context.junit4. SpringJUnit4ClassRunner和Mockito），我嘲笑了MyService并将其作为Spring bean注入单元测试：

MyService myService = Mockito.mock(MyService.class);

然后，我尝试这样做来模拟服务引发异常：

IllegalArgumentException myException = new IllegalArgumentException();
Mockito.doThrow(myException).when(myService).myMethod();

... 但我正在测试的方法的catch块中从未发现异常。

这可能与代码正在使用另一个线程调用myService有关。myMethod（）。

是否有任何方法可以获取myService引发的异常。要正确捕获myMethod（）？

提前感谢任何帮助。

Answer 1

您的代码执行顺序如何？首先您需要设置您的mock，然后运行它。

MyService myService = Mockito.mock(MyService.class);
Mockito.when(myService.myMethod()).doThrow(myexception.class); // try in this order


try {
    new Thread(() -> myService.myMethod()).start();
    return new MyResponse("Done");
} catch (Exception exception) {
    throw new MyException("Internal Error", exception);
}

顺便说一下，如果您使用的是java 8或更高版本，您可能希望使用CompletableFuture包。也就是说，CompletableFuture。SupplySync（（）-

Answer 2

“外部”线程可以捕获另一个线程中的异常是没有意义的。如果在代码中添加上下文，例如

Thread th = new Thread(() -> { Thread.sleep(10000); throw new RuntimeException(); });
try { th.start(); } catch (Exception e) {
    System.out.println("uh-oh");
}
for (int i = 0; i < 1000; i++){
    System.out.println("running " + i);
    Thread.sleep(1000);
}

线程已启动，并将在10秒后引发异常。然而，开始线程已转到每秒计数。如果启动线程的异常将被捕获，您是否希望主线程返回到捕获异常的位置？是否应中断计数，然后继续？不继续？

您所能做的最好的事情可能是指定一个错误处理程序（就像Roger在评论中提到的那样），但您必须以实际的间隔从主线程查询其状态，因为它将在并发启动的线程中运行。

考虑到t=new Thread（）；t.start（）；不建议再使用，最简单的方法是使用CompletableFutureIMO：

CompletableFuture<Void> future = 
    CompletableFuture.runAsync(() -> myService.myMethod());

现在，您可以稍后查询发生了什么：

if (future.isDone()) // task has finished in any way

if (future.isDone() && future.isCompletedExceptionally()) // task was finished because an exception was thrown