diff --git a/store/src/test/java/org/apache/rocketmq/store/lock/AdaptiveLockTest.java b/store/src/test/java/org/apache/rocketmq/store/lock/AdaptiveLockTest.java index ac1b3c60cc..c24a1dccae 100644 --- a/store/src/test/java/org/apache/rocketmq/store/lock/AdaptiveLockTest.java +++ b/store/src/test/java/org/apache/rocketmq/store/lock/AdaptiveLockTest.java @@ -78,9 +78,11 @@ public class AdaptiveLockTest { } assertTrue(adaptiveLock.getAdaptiveLock() instanceof BackOffReentrantLock); - adaptiveLock.lock(); - Thread.sleep(1000); - adaptiveLock.unlock(); + for (int i = 0; i <= 2; i++) { + adaptiveLock.lock(); + adaptiveLock.unlock(); + Thread.sleep(1000); + } assertTrue(adaptiveLock.getAdaptiveLock() instanceof BackOffSpinLock); } }