##// END OF EJS Templates
caches: further improvements on the lock implementations
super-admin -
r952:757fecd5 default
parent child Browse files
Show More
@@ -288,11 +288,8 b' def get_mutex_lock(client, lock_key, loc'
288 class _RedisLockWrapper(object):
288 class _RedisLockWrapper(object):
289 """LockWrapper for redis_lock"""
289 """LockWrapper for redis_lock"""
290
290
291 def __init__(self):
291 @classmethod
292 pass
292 def get_lock(cls):
293
294 @property
295 def lock(self):
296 return redis_lock.Lock(
293 return redis_lock.Lock(
297 redis_client=client,
294 redis_client=client,
298 name=lock_key,
295 name=lock_key,
@@ -301,8 +298,14 b' def get_mutex_lock(client, lock_key, loc'
301 strict=True,
298 strict=True,
302 )
299 )
303
300
301 def __init__(self):
302 self.lock = self.get_lock()
303
304 def acquire(self, wait=True):
304 def acquire(self, wait=True):
305 try:
305 return self.lock.acquire(wait)
306 return self.lock.acquire(wait)
307 except redis_lock.AlreadyAquited:
308 return False
306
309
307 def release(self):
310 def release(self):
308 try:
311 try:
General Comments 0
You need to be logged in to leave comments. Login now