调用void方法的CompletableFuture.runAsync（）的Mockito测试用例

Question

public void getCouponAndNotifyAsync(String countryId, String channelId,
        String storeNumber, String clientId, NotificationRequest notificationRequest)
        throws FirestoreException, TurneroServiceException {
    CompletableFuture.runAsync(() -> getCouponAndNotify(countryId, channelId,
            storeNumber, clientId, notificationRequest));
}

@Test
    public void getCouponAndNotifyAsync() throws Exception {
        //doNothing().when(turneroService).getCouponAndNotify(COUNTRYID, CHANNELID, STORENUMBER, CLIENTID, new NotificationRequest("[e-mail]", "all"));

        CompletableFuture<Void> runAsync = CompletableFuture
                .runAsync(() -> doNothing().when(turneroService).getCouponAndNotify(COUNTRYID, CHANNELID, STORENUMBER, CLIENTID, new NotificationRequest("[e-mail]", "all")));

        assertTrue(runAsync.isDone());

    }

已更新测试用例，但仍不工作。

@Test
    public void getCouponAndNotifyAsync() throws Exception {
        //doNothing().when(turneroService).getCouponAndNotify(COUNTRYID, CHANNELID, STORENUMBER, CLIENTID, new NotificationRequest("[e-mail]", "all"));

        CompletableFuture<Void> runAsync = CompletableFuture
                .runAsync(() -> doNothing().when(turneroService).getCouponAndNotify(COUNTRYID, CHANNELID, STORENUMBER, CLIENTID, new NotificationRequest("[e-mail]", "all")));

        assertTrue(ForkJoinPool.commonPool().awaitQuiescence(5, TimeUnit.SECONDS));
        assertTrue(runAsync.isDone());

    }

Answer 1

我假设您正在其他地方测试getCouponandNotify()，这样您就不必担心它会引发异常。

您将遇到的是getCouponandNotifyAsync()和getCouponandNotify()返回之间的竞争条件。对此有几种解决方案：

由于您使用的是通用的forkjoinpool，请执行以下操作

assertTrue(ForkJoinPool.commonPool().awaitQuiescence(5, TimeUnit.Seconds));