0

我正在测试 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"

我究竟做错了什么 ???

4

0 回答 0