-
Notifications
You must be signed in to change notification settings - Fork 2
/
4_condition_wait_notify.py
54 lines (43 loc) · 1.53 KB
/
4_condition_wait_notify.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
import threading
import time
condition = threading.Condition()
products = 0
class Producer(threading.Thread):
def __init__(self):
threading.Thread.__init__(self)
def run(self):
global condition, products
while True:
if condition.acquire():
if(products<10):
products += 1
print('{0}: produce one, now products={1}'.format(self.name, products))
condition.notify()
else:
print('{0}: now products=10, stop product'.format(self.name))
condition.wait()
condition.release()
time.sleep(2)
class Consumer(threading.Thread):
def __init__(self):
threading.Thread.__init__(self)
def run(self):
global condition, products
while True:
if condition.acquire():
if(products>=1):
products -= 1
print('{0}: consume one, now products={1}'.format(self.name, products))
condition.notify()
else:
print('{0}: now products=0, wait'.format(self.name))
condition.wait()
condition.release()
time.sleep(2)
if __name__ == '__main__':
for i in range(2):
th_producer = Producer()
th_producer.start()
for i in range(10):
th_consumer = Consumer()
th_consumer.start()