Condition锁机制
#-------------------------------------------------------------------------
import threading
import time
import random
gMoney = 1000
gTimesT = 10
gTimes = 0
gCondition= threading.Condition()
class Producer(threading.Thread):
def run(self):
global gMoney
global gTimesT
global gTimes
while True:
money = random.randint(100,1000)
gCondition.acquire()
if gTimes >= gTimesT:
gCondition.release()
break
gMoney += money
print('%s生产了%d元钱,剩余%d元钱'%(threading.current_thread(),money,gMoney))
gTimes +=1
gCondition.notify_all()
gCondition.release()
time.sleep(0.5)
class Consumer(threading.Thread):
def run(self):
global gMoney
global gTimesT
global gTimes
while True:
money = random.randint(100,1000)
gCondition.acquire()
while gMoney <= money:
if gMoney >= money:
gCondition.release()
return
print('%s消费者消费%d元钱,剩余%d元钱,不足!'% (threading.current_thread(),money,gMoney))
gCondition.wait()
gMoney -= money
print('%s消费了%d元钱,剩余%d元钱'%(threading.current_thread(),money,gMoney))
gCondition.release()
time.sleep(0.5)
def main():
for x in range(3):
t = Consumer(name='消费者%d'%x)
t.start()
for x in range(5):
t = Producer(name='生产者%d'%x)
t.start()
if __name__ =="__main__":
main()