We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6148b89 commit d9d5e93Copy full SHA for d9d5e93
store/src/test/java/org/apache/rocketmq/store/lock/AdaptiveLockTest.java
@@ -78,9 +78,11 @@ public void run() {
78
}
79
assertTrue(adaptiveLock.getAdaptiveLock() instanceof BackOffReentrantLock);
80
81
- adaptiveLock.lock();
82
- Thread.sleep(1000);
83
- adaptiveLock.unlock();
+ for (int i = 0; i <= 2; i++) {
+ adaptiveLock.lock();
+ adaptiveLock.unlock();
84
+ Thread.sleep(1000);
85
+ }
86
assertTrue(adaptiveLock.getAdaptiveLock() instanceof BackOffSpinLock);
87
88
0 commit comments