Python实现的redis分布式锁功能示例

#!/usr/bin/env python
# coding=utf-8
import time
import redis
class RedisLock(object):
def __init__(self, key):
self.rdcon = redis.Redis(host='', port=6379, password="", db=1)
self._lock = 0
self.lock_key = "%s_dynamic_test" % key
@staticmethod
def get_lock(cls, timeout=10):
while cls._lock != 1:
timestamp = time.time() + timeout + 1
cls._lock = cls.rdcon.setnx(cls.lock_key, timestamp)
if cls._lock == 1 or (time.time() > cls.rdcon.get(cls.lock_key) and time.time() > cls.rdcon.getset(cls.lock_key, timestamp)):
print "get lock"
break
else:
time.sleep(0.3)
@staticmethod
def release(cls):
if time.time() < cls.rdcon.get(cls.lock_key):
print "release lock"
cls.rdcon.delete(cls.lock_key)
def deco(cls):
def _deco(func):
def __deco(*args, **kwargs):
print "before %s called [%s]."%(func.__name__, cls)
cls.get_lock(cls)
try:
return func(*args, **kwargs)
finally:
cls.release(cls)
return __deco
return _deco
@deco(RedisLock("112233"))
def myfunc():
print "myfunc() called."
time.sleep(20)
if __name__ == "__main__":
myfunc()

更多关于Python相关内容感兴趣的读者可查看本站专题：《Python常见数据库操作技巧汇总》、《Python编码操作技巧总结》、《Python数据结构与算法教程》、《Python Socket编程技巧总结》、《Python函数使用技巧总结》、《Python字符串操作技巧汇总》、《Python入门与进阶经典教程》及《Python文件与目录操作技巧汇总》

希望本文所述对大家Python程序设计有所帮助。

您可能感兴趣的文章:

• python中redis查看剩余过期时间及用正则通配符批量删除key的方法
• python操作redis方法总结
• Python操作Redis之设置key的过期时间实例代码
• python实现redis三种cas事务操作
• Python 用Redis简单实现分布式爬虫的方法
• python脚本实现Redis未授权批量提权
• 在Python中使用AOP实现Redis缓存示例
• python笔记:mysql、redis操作方法
• Windows下安装Redis及使用Python操作Redis的方法
• python中redis的安装和使用
• Python的Flask框架使用Redis做数据缓存的配置方法
• Python的Flask框架应用调用Redis队列数据的方法
• python安装与使用redis的方法
• Python使用redis pool的一种单例实现方式
• Python使用Redis实现作业调度系统(超简单)
• python操作redis的方法
• Redis的Python客户端redis-py安装使用说明文档
• Python连接Redis的基本配置方法