我正在测试 redisson 的分布式锁是否可以正常工作,使用 kotlin 和协程。
runBlocking {
repeat(1000) {
launch {
val lock = nonReactiveClient.getLock("lock")
if(lock.tryLock(5, 5, TimeUnit.SECONDS)) {
try {
val value = test.get()
delay(10L)
test.set(value + 3)
} finally {
lock.unlock()
}
}
}
}
}
我认为结果值应该是 3000,因为分布式锁保证了 'get' 和 'set' 操作会原子地一起执行。
但是当我试图获得价值时,我得到了以下结果:
127.0.0.1:6379> get test
"3"
我究竟做错了什么 ???