分布式锁¶
基于 Lua 脚本原子操作的 Redis 分布式锁。
基本锁¶
from redis_kit import Lock
lock = Lock(conn.sync_client, prefix="myapp:lock")
with lock("resource-1", timeout=10):
do_critical_work()
可重入锁¶
with lock("resource", timeout=10, reentrant=True):
with lock("resource", timeout=10, reentrant=True):
... # No deadlock
读写锁¶
# 读锁支持 blocking_timeout 重试等待
with lock.read("resource", blocking_timeout=5.0):
data = read_shared_state()
# 写锁支持 auto_renew 自动续期
with lock.write("resource", auto_renew=True):
update_shared_state()
看门狗自动续期¶
with lock("resource", timeout=30, auto_renew=True):
do_long_running_work() # Lock auto-extends every 10s
集群模式¶
lock = Lock(conn.sync_client, prefix="myapp:lock", is_cluster=conn.is_cluster)
# Keys automatically wrapped in {hash_tag} for Lua script slot safety
异常安全¶
所有锁的上下文管理器（__call__、read()、write()）都保证不会遮蔽你代码中抛出的原始异常。如果锁释放失败（例如锁已超时过期），而你的代码同时抛出了异常，原始异常将正常传播，释放失败仅记录警告日志。
try:
with lock("resource", timeout=5):
raise ValueError("业务逻辑错误")
except ValueError:
# ValueError 会正常传播，即使锁释放失败也不会被 LockReleaseError 遮蔽
pass
# 读写锁同样异常安全
try:
with lock.write("resource", timeout=5):
raise ValueError("写操作异常")
except ValueError:
pass # 原始异常正常传播
在正常退出（无异常）时，如果锁释放失败则会抛出 LockReleaseError。
读写锁为读者优先策略
在高竞争场景下，持续的读操作可能导致写操作饥饿。如果你的场景写操作较频繁，请注意这一设计特性。