fix: less cancel failure

songzhibin97 · Apr 18, 2024 · 1ed675c · 1ed675c
1 parent f2833db
commit 1ed675c
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/distributed/locker/lock_ridis/lease.go b/distributed/locker/lock_ridis/lease.go
@@ -101,8 +101,11 @@ func LeaseLock(lock locker.Locker, key string, expire int, ops ...options.Option
 	}
 
 	return func() error {
+		if cls.Load() {
+			return nil
+		}
 		cls.Store(true)
-		cancel()
+		defer cancel()
 		return lock.UnLock(key, mark)
 	}, nil
 }