summaryrefslogtreecommitdiff
path: root/kombu/clocks.py
diff options
context:
space:
mode:
Diffstat (limited to 'kombu/clocks.py')
-rw-r--r--kombu/clocks.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/kombu/clocks.py b/kombu/clocks.py
index a45bc767..aecb68fb 100644
--- a/kombu/clocks.py
+++ b/kombu/clocks.py
@@ -11,7 +11,7 @@ Logical Clocks and Synchronization.
from __future__ import absolute_import
from __future__ import with_statement
-from threading import Lock
+import threading
__all__ = ['LamportClock']
@@ -57,7 +57,7 @@ class LamportClock(object):
def __init__(self, initial_value=0):
self.value = initial_value
- self.mutex = Lock()
+ self.mutex = threading.Lock()
def adjust(self, other):
with self.mutex: