java - ScheduledThreadPoolExecutor 的单元测试

Question

假设我有这样的方法

public void scheduleCleanup(String parameter) {
    final SomeObject someObject = new SomeObject(parameter);
    ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(1);
    executor.schedule((Runnable) () -> cleanupService.startCleanup(someObject),
                CLEANUP_TIMEOUT_SEC, TimeUnit.SECONDS);
}

这意味着 cleanupService.startCleanup(someObject) 在 CLEANUP_TIMEOUT_SEC 之后调用，这实际上来自某些属性文件。

对我来说，很明显我可以创建 SomeObject 并为 cleanupService.startCleanup(someObject) 编写单元测试，但是我如何处理 scheduleCleanup 方法？

1. 我假设我需要模拟它，但在这种情况下您如何做？
2. 是否可以避免模拟？在这种情况下最好的方法是什么？

Answer 1

我猜您想避免在单元测试中使用/调用 ScheduledThreadPoolExecutor。我会用 ScheduledExecutorService 替换 ScheduledThreadPoolExecutor 并将其注入(inject)到类中:

@Inject ExecutorService executor;

public void scheduleCleanup(String parameter) {
   final SomeObject someObject = new SomeObject(parameter);
   executor.schedule((Runnable) () -> cleanupService.startCleanup(someObject),
            CLEANUP_TIMEOUT_SEC, TimeUnit.SECONDS);
}

然后您可以简单地验证是否在适当的位置调用了 executor.schedule(Runnable, long, TimeUnit)。