使用了redis分布式锁避免死锁的代码

以下是一个使用 Redis 分布式锁避免死锁的示例代码：

import redis
import time

class RedisLock(object):
    def __init__(self, key, timeout=10, sleep=0.1):
        self.key = key
        self.timeout = timeout
        self.sleep = sleep
        self.redis = redis.Redis(host='localhost', port=6379, db=0)

    def acquire(self):
        while self.timeout >= 0:
            now = time.time()
            expires = now + self.timeout + 1  # 锁的超时时间
            if self.redis.setnx(self.key, expires):  # 尝试获取锁
                return expires
            else:
                current_value = self.redis.get(self.key)
                if current_value and now > float(current_value):  # 判断锁是否已经过期
                    old_value = self.redis.getset(self.key, expires)
                    if old_value and old_value == current_value:  # 防止多个进程同时释放锁
                        return expires
            self.timeout -= self.sleep
            time.sleep(self.sleep)
        return False

    def release(self):
        self.redis.delete(self.key)

# 使用示例
lock = RedisLock("my_lock")
expires = lock.acquire()
if expires:
    # 获取锁成功，执行需要加锁的代码
    print("do something...")
    lock.release()
else:
    print("failed to get lock")

这个示例代码中，我们使用了 Redis 的 SETNX 命令来尝试获取锁。如果获取锁成功，那么 SETNX 命令会返回 1，并且我们会得到一个锁的超时时间。如果获取锁失败，我们会检查锁是否已经过期，如果过期了，我们会使用 GETSET 命令来尝试更新锁的超时时间。如果 GETSET 命令返回的值与之前一样，说明我们成功获取了锁。如果 GETSET 命令返回的值与之前不一样，说明有其他进程已经获取了锁。