1 import time 2 import redis 3 from redis.exceptions import watcherror 4 5 6 class redisutil(): 7 def __init__(self): 8 self.redis = redis.redis(host="redis账户url", 9 port=6379,10 password="你的redis密码",11 decode_responses=true)12 self.online_set_name = "palm_online_devices"13 14 # 获取锁15 def acquire_lock(self, key, val, acquire_time=60, time_out=60):16 start_time = time.time()17 # 阻塞等待，轮询去获取锁，获取不到，轮询等待，直到拿到锁或者超时18 while true:19 if time.time() - start_time > acquire_time:20 return false21 # 用setnx实现分布式锁，当key存在时候，setnx不做任何动作，如果key不存在，将value值设置为val22 # 如果 setnx 返回1，说明该进程获得锁，setnx将键 lock.foo 的值设置为锁的超时时间（当前时间 + 锁的有效时间）。23 # 如果 setnx 返回0，说明其他进程已经获得了锁，进程不能进入临界区。进程可以在一个循环中不断地尝试 setnx 操作，以获得锁24 if self.redis.setnx(name=key, value=val):25 # 设置key的时长为60秒，如果超过60秒，key销毁26 self.redis.expire(key, time_out)27 return true28 29 # 释放锁30 def release_lock(self, key, val):31 pip = self.redis.pipeline(true)32 while true:33 try:34 pip.watch(key)35 lock_value = self.redis.get(key)36 if not lock_value:37 return true38 if lock_value == val:39 pip.multi()40 pip.delete(key)41 pip.execute()42 return true43 pip.unwatch()44 break45 except watcherror:46 pass47 return false
python可以做什么
python是一种编程语言，内置了许多有效的工具，python几乎无所不能，该语言通俗易懂、容易入门、功能强大，在许多领域中都有广泛的应用，例如最热门的大数据分析，人工智能，web开发等。
