我正在测试redisson的分布式锁是否正确工作,使用kotlin和coroutine。
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"
我做错什么了?
发布于 2022-04-17 06:59:21
在Coroutines中,在delay
之后,可以更改线程上下文。
lock.tryLock
-线程id - 77
lock.unlock
-线程id - 88 (无限等待)
您可以在不同线程id下使用forceUnlock()
。
https://stackoverflow.com/questions/62278579
复制相似问题