Awaitility项目中RejectedExecutionException异常分析与解决方案

背景介绍

在使用Awaitility进行异步测试时，开发人员经常会遇到RejectedExecutionException异常。这种异常通常出现在测试代码中使用await()方法等待某些异步操作完成时，特别是在与资源解析器（如Apache Jackrabbit Oak）交互的场景中。

问题现象

典型的错误日志如下：

[ERROR] VirtualDetailPageServletTest.successful » RejectedExecution Task org.apache.jackrabbit.oak.commons.concurrent.NotifyingFutureTask@2115ecb[Not completed, task = org.apache.jackrabbit.oak.spi.commit.BackgroundObserver$1$1@339038ca] rejected from java.util.concurrent.ThreadPoolExecutor@60ecde41[Shutting down, pool size = 1, active threads = 1, queued tasks = 0, completed tasks = 9]

这种错误表明线程池正在关闭时，新的任务被拒绝执行。

根本原因分析

1. 线程池生命周期问题：当测试环境中的线程池正在关闭过程中（状态为Shutting down），新的任务提交会被拒绝
2. 资源竞争：测试中可能有多个线程同时尝试访问资源解析器，导致线程池过载
3. 超时设置不当：10分钟的等待时间可能过长，增加了线程池压力

解决方案

方案一：忽略特定异常

最简单的解决方案是在await条件中添加异常忽略：

await()
    .ignoreException(RejectedExecutionException.class)
    .atMost(10, TimeUnit.MINUTES)
    .until(() -> context.resourceResolver().resolve("/something"), path("/content/something"));

方案二：优化线程池配置

1. 增加线程池大小
2. 使用更合理的拒绝策略（如CallerRunsPolicy）
3. 确保测试前后正确初始化和清理线程池

方案三：调整等待策略

1. 缩短最大等待时间
2. 添加轮询间隔配置

await()
    .pollInterval(1, TimeUnit.SECONDS)
    .atMost(1, TimeUnit.MINUTES)
    .until(...);

最佳实践建议

1. 合理设置超时：根据实际业务场景设置适当的等待时间，避免过长等待
2. 异常处理：明确哪些异常可以忽略，哪些需要处理
3. 资源管理：确保测试环境中的资源（如线程池）得到正确管理
4. 日志记录：添加详细的日志记录，帮助诊断问题

总结

在Awaitility测试中遇到RejectedExecutionException时，开发者应该首先理解这是线程池管理问题而非Awaitility本身的问题。通过合理的异常处理和资源管理配置，可以有效地解决这类问题，确保测试的稳定性和可靠性。对于长期运行的测试，建议采用更细粒度的等待策略和更完善的资源管理方案。