关于IDatabaseExtension中Lock和LockAsync方法的困惑

[q5401103q]

我认为 StackExchange.Redis.IDatabaseExtension 类的Lock和LockAsync方法可能存在问题。具体代码如下：

public static (bool Success, string LockValue) Lock(this IDatabase redisDb, string cacheKey, int timeoutSeconds = 5, bool autoDelay = true)
{
    //其他代码...

    //通过GetLockKey方法获取到字符串，形如 adnc:locker:xxx
    var lockKey = GetLockKey(cacheKey); 

    //其他代码...

    //将其写入Redis
    bool flag = await redisDb.StringSetAsync(lockKey, lockValue, expiration, When.NotExists);
    
    //其他代码...
    if (!addResult)
    {
        autoDelayTimer?.Dispose();
        
        //这里将lockKey传参到SafedUnLock方法
        redisDb.SafedUnLock(lockKey, lockValue); 
        return (false, null);
    }
}

//SafedUnLock方法截取
public static bool SafedUnLock(this IDatabase redisDb, string cacheKey, string lockValue)
{
    //其他代码...
 
    //通过GetLockKey方法获取到字符串，形如 adnc:locker:adnc-locker-xxx
    var lockKey = GetLockKey(cacheKey);
    AutoDelayTimers.Instance.CloseTimer(lockKey);

    var script = @"local invalue = @value
                   local currvalue = redis.call('get',@key)
                   if(invalue==currvalue) then redis.call('del',@key)
                       return 1
                   else
                       return 0
                   end";
    var parameters = new { key = lockKey, value = lockValue };
    var prepared = LuaScript.Prepare(script);
    
    //由于无法找到，result的值恒为0，意味着解锁不会成功
    var result = (int)redisDb.ScriptEvaluateAsync(prepared, parameters).GetAwaiter().GetResult();
    return result == 1;
}

LockAsync方法存在同样的问题。
以上仅是个人意见，请作者指点。

[AlphaYu]

谢谢您细心发现的问题，分布式锁确实在加锁成功并且开启自动续期的情况下，如果加入Timer队列失败，再解锁时有问题。该Bug @AjuPrince 已经修复。 #24