我想使用Redis进行分布式锁定。我为此使用RedLock.net nuget包。
但是线程能够获取锁,即使另一个线程已经获取了锁。
这是示例代码:
public void Demo(RedLockFactory redLockFactory)
{
Parallel.For(0, 5, x =>
{
TimeSpan expiry = TimeSpan.FromSeconds(30);
var wait = TimeSpan.FromSeconds(10);
var retry = TimeSpan.FromSeconds(1);
string user = $"User:{x}";
using (var redLock = redLockFactory.CreateLock(resource, expiry, wait, retry))
{
// make sure we got the lock
if (redLock.IsAcquired)
{
Console.WriteLine($"{user} acquired lock at {DateTimeOffset.Now.ToString("dd-MM-yyyy HH:mm:ss")}.");
}
else
{
Console.WriteLine($"{user} didn't get the lock.");
}
}
});
}
这是我的演示的输出User:4 acquired lock at 06-10-2020 09:24:34.
User:2 acquired lock at 06-10-2020 09:24:34.
User:1 acquired lock at 06-10-2020 09:24:34.
User:0 acquired lock at 06-10-2020 09:24:35.
User:3 acquired lock at 06-10-2020 09:24:35.
如您所见,每个线程都可以获取锁,这是不应该发生的。一旦获取了锁,则其他线程应该无法获取该锁。
最佳答案
对于RedLock.net/README.md,“该锁将在using块的结尾自动释放”。
所以我认为您的演示输出中发生的是:
using
块中传递出去,释放其锁定(现在另一个线程可以胜出)如果您希望看到锁获取失败,请在退出
using
块之前进行非常慢的操作(> 10秒)。出于演示目的,您可以在写入“acquired”行之后使用Thread.Sleep(15000)
。