第二十节 condition版生产者和消费者

import threading
import time
import random


gMoney = 1000
gCondition = threading.Condition()
gtime = 0

class Producer(threading.Thread):
    def run(self):
        global gMoney
        global gtime
        while 1:
            money = random.randint(100,1000)
            if gtime <= 9:
                gCondition.acquire()
                gMoney += money
                print('%s生产了%d,账户总余额%d'%(threading.current_thread(),money,gMoney))
                gCondition.notify_all()
                gCondition.release()
                gtime +=1
            else:
                break
            time.sleep(0.5)

            
class Consumer(threading.Thread):
    def run(self):
        global gMoney
        global gtime
        while 1:
            money = random.randint(100,1000)
            gCondition.acquire()
            while gMoney < money:
                if gtime >=10:
                    gCondition.release()
                    return
                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(5):
        t = Producer()
        t.start()
    for x in range(5):
        t = Consumer()
        t.start()

if __name__ == '__main__':
    main()