Mockito Junit Test - "通缉但未被调用;但是，与此模拟"错误还有其他交互

Question

>我必须在超时的情况下运行可处理的未来函数。仅当原始方法花费的时间超过给定的超时时，才应调用可运行函数。单位不断给予= 想要但未调用：但是，与此模拟正好有 3 次交互。

我正在尝试做的是，我正在尝试为方法执行添加超时(getResponseWithTimeoutFunction(itemRequest))，如果该方法需要更多时间，则终止它并发布计数(以了解超时响应率)作为指标。

@Test
public void testTimeoutFunction() throws Exception {
Response response = getResponseForTest(); 
when(requestAdapter.transform(itemRequest)).thenReturn(Request);
when(dataProvider
.provide(any(Request.class)))
.thenAnswer((Answer<Response>) invocation -> {
Thread.sleep(1000000);
return response;
});
processor = spy(getProcessor());
when(itemRequest.getRequestContext()).thenReturn(itemRequestContext);
when(itemRequestContext.getMetadata()).thenReturn(requestContextMetadata);
List<Item> output = processor.getItemist(ITEM_ID, itemRequest);
assertTrue(output.isEmpty());
verify(processor, times(1)).processRequest(Request);
verify(processor, times(1)).responseTimedOutCount();
}

这是我正在测试的方法：

public class Process {
@VisibleForTesting
void  responseTimedOutCount() {
//log metrics
}
private CompletableFuture<Response> getResponseAsync(final ScheduledExecutorService delayer,
       final ItemRequest itemRequest) {
return timeoutWithTimeoutFunction(delayer, EXECUTION_TIMEOUT, TimeUnit.MILLISECONDS,
CompletableFuture.supplyAsync(() -> getResponseWithTimeoutFunction(itemRequest), executorService),
Response.emptyResponse(), () -> responseTimedOutCount());
}

private Response getResponseWithTimeoutFunction(final ItemRequest itemRequest) {
//do something and return response
}
public List<Item> getItemList(final String id, final ItemRequest itemRequest) throws Exception {
final ScheduledExecutorService delayer = Executors.newScheduledThreadPool(1);
Response response;
if(validateItemId(id){
try {
response = getResponseAsync(delayer, itemRequest).get();
} catch (final Throwable t) {
response = Response.emptyResponse();
} finally {
delayer.shutdown();
}
return transform(response, id).getItems(); 
} else {
return null;
}
}
}

而超时函数使用=

public static <T> CompletableFuture<T> timeoutWithTimeoutFunction(final ScheduledExecutorService es,
final long timeout,
final TimeUnit unit,
final CompletableFuture<T> f,
final T defaultValue,
final Runnable r) {
final Runnable timeoutFunction = () -> {
boolean timedOut = f.complete(defaultValue);
if (timedOut && r != null) {
r.run();
}
};
es.schedule(timeoutFunction, timeout, unit);
return f;
}

来自Junit的例外：

Wanted but not invoked: process.responseTimedOutCount(); -> at processTest.testTimeoutFunction(processTest.java:377) 
However, there were exactly 3 interactions with this mock: 
process.getItemList( ITEM_ID, itemRequest ); -> at processTest.testTimeoutFunction(processTest.java:373) 
process.validateItemId( ITEM_ID ); -> at process.getItemList(process.java:133) 
process.processRequest( request ); -> at process.getResponseWithTimeoutFunction(process.java:170)

Answer 1

要测试超时，您可能希望模拟要测试超时的呼叫。相对于测试的持续时间，它应该永远需要。

when(dataProvider
.provide(any(Request.class)))
.thenAnswer((Answer<Response>) invocation -> {
Thread.sleep(FOREVER);
return response;
});

验证应具有线程处理超时。当超时时间很长时，您可能应该确保它是可配置的，以允许快速测试。像verify(mock, timeout(LONGER_THAN_REAL_TIMEOUT)).someCall()

确保对总测试持续时间设置超时，以确保当前或将来的故障不会减慢生成速度。

Answer 2

要测试异步调用，您可以使用：

verify(processor, timeout(1000)).processRequest(request);