|
|
@ -218,7 +218,7 @@ public class RedissonFairLock extends RedissonLock implements RLock {
|
|
|
|
// threadWaitTime
|
|
|
|
// threadWaitTime
|
|
|
|
"local lastThreadId = redis.call('lindex', KEYS[2], -1);" +
|
|
|
|
"local lastThreadId = redis.call('lindex', KEYS[2], -1);" +
|
|
|
|
"local ttl;" +
|
|
|
|
"local ttl;" +
|
|
|
|
"if lastThreadId ~= false and lastThreadId ~= ARGV[2] then " +
|
|
|
|
"if lastThreadId ~= false and lastThreadId ~= ARGV[2] and redis.call('zscore', KEYS[3], lastThreadId) ~= false then " +
|
|
|
|
"ttl = tonumber(redis.call('zscore', KEYS[3], lastThreadId)) - tonumber(ARGV[4]);" +
|
|
|
|
"ttl = tonumber(redis.call('zscore', KEYS[3], lastThreadId)) - tonumber(ARGV[4]);" +
|
|
|
|
"else " +
|
|
|
|
"else " +
|
|
|
|
"ttl = redis.call('pttl', KEYS[1]);" +
|
|
|
|
"ttl = redis.call('pttl', KEYS[1]);" +
|
|
|
|