Skip to content

Commit 2455a33

Browse files
committed
Fixed typo in consumer
1 parent e17beb8 commit 2455a33

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

intro_to_threading/prodcom_lock.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -14,12 +14,12 @@ class Pipeline:
1414
def __init__(self):
1515
self.message = 0
1616
self.producer_lock = threading.Lock()
17-
self.comsumer_lock = threading.Lock()
18-
self.comsumer_lock.acquire()
17+
self.consumer_lock = threading.Lock()
18+
self.consumer_lock.acquire()
1919

2020
def get_message(self, name):
2121
logging.debug("%s:about to acquire getlock", name)
22-
self.comsumer_lock.acquire()
22+
self.consumer_lock.acquire()
2323
logging.debug("%s:have getlock", name)
2424
message = self.message
2525
logging.debug("%s:about to release setlock", name)
@@ -33,7 +33,7 @@ def set_message(self, message, name):
3333
logging.debug("%s:have setlock", name)
3434
self.message = message
3535
logging.debug("%s:about to release getlock", name)
36-
self.comsumer_lock.release()
36+
self.consumer_lock.release()
3737
logging.debug("%s:getlock released", name)
3838

3939

0 commit comments

Comments
 (0)