我有一个要测试的方法的实现。
@Override
public void onMessage(final Message message) {
try {
LOG.fine("waiting on semaphore for " + message);
semaphore.acquire();
LOG.fine("semaphore acquired for " + message);
listener.onMessage(message);
LOG.fine(message + " processed");
} catch (final InterruptedException e) {
throw new RuntimeException(e);
} finally {
semaphore.release();
}
}
但是,我不确定如何从 JUnit 测试中触发 InterruptedException。理论上我可以添加钩子来终止它,但这会污染代码库,代码只用于我想避免的测试。