Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

LamportClock: can now set Lock class

This commit is contained in:
Ask Solem 2013-09-11 21:45:09 +01:00
parent a136c7b434
commit d260459269
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
kombu/clocks.py
View File

@ -54,7 +54,7 @@ class LamportClock(object):
#: The clocks current value. #: The clocks current value.
value = 0 value = 0
def __init__(self, initial_value=0): def __init__(self, initial_value=0, Lock=Lock):
self.value = initial_value self.value = initial_value
self.mutex = Lock() self.mutex = Lock()