在 Redis 中實現并發鎖，可以使用 SETNX（SET if Not eXists）指令。該指令會在鍵不存在時設置鍵的值，如果鍵已經存在，則不執行任何操作。
在并發鎖的場景中，可以將鎖的持有者設置為一個唯一的標識，比如使用線程或進程的 ID。為了避免死鎖，通常會為鎖設置一個過期時間，即在一定時間后自動釋放鎖。
以下是一個設置并發鎖的示例代碼：
import time
import redis
# 連接 Redis
r = redis.Redis(host='localhost', port=6379)
def acquire_lock(lock_key, expire_time):
while True:
# 嘗試獲取鎖
lock_acquired = r.setnx(lock_key, 'locked')
# 鎖獲取成功
if lock_acquired:
# 設置鎖的過期時間
r.expire(lock_key, expire_time)
return True
# 鎖獲取失敗，等待一段時間后重試
time.sleep(0.1)
def release_lock(lock_key):
# 刪除鎖
r.delete(lock_key)
# 使用示例
lock_key = 'my_lock'
expire_time = 10 # 鎖的過期時間為 10 秒
if acquire_lock(lock_key, expire_time):
try:
# 執行需要加鎖的操作
print("Do something here...")
finally:
# 釋放鎖
release_lock(lock_key)
在上述示例中，acquire_lock 函數嘗試獲取鎖，如果獲取成功，則設置鎖的過期時間，并返回 True。如果獲取失敗，則等待一段時間后重試。release_lock 函數用于釋放鎖，即刪除鎖鍵。
鎖的過期時間應根據實際情況進行設置。如果鎖的過期時間太短，可能會導致鎖被過早釋放，從而導致并發沖突。如果鎖的過期時間太長，可能會導致鎖一直被持有，從而影響其他請求的執行。
因此，在設置鎖的過期時間時，需要根據具體的業務場景和性能需求來確定。一般來說，可以根據業務操作的預估執行時間來設置鎖的過期時間，留出一定的冗余時間以確保操作的完成。
