This is an automated email from the ASF dual-hosted git repository.
lizhimin pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new d9d5e93135 [ISSUE #9177] Fix unstable tests in
AdaptiveLockTest.testAdaptiveLock (#9178)
d9d5e93135 is described below
commit d9d5e931354fc13b7e5469aad5c0ad66869527e7
Author: hqbfz <[email protected]>
AuthorDate: Wed Feb 12 16:44:34 2025 +0800
[ISSUE #9177] Fix unstable tests in AdaptiveLockTest.testAdaptiveLock
(#9178)
---
.../java/org/apache/rocketmq/store/lock/AdaptiveLockTest.java | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
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);
}
}