第十九节 lock版生产者和消费者

import threading
import time
import random


gMoney = 1000
gLock = threading.Lock()

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


class Consumer(threading.Thread):
    def run(self):
        global gMoney
        while 1:
            money = random.randint(100,1000)
            if gMoney >= money:
                gLock.acquire()
                gMoney -= money
                print('%s消费了%d，账户余额%d'%(threading.current_thread(),money,gMoney))
                gLock.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()