python-生产者消费者模式

#!/usr/bin/python
#coding=utf-8

import threading,time
lock=threading.Condition()
product=0
class Make(threading.Thread):
    def __init__(self,lock):
        self.lock=lock
        super(Make,self).__init__()

    def run(self):
        global product
        while 1:
            if self.lock.acquire():
                if product>=1000:
                    self.lock.wait()
                else:
                    product+=100
                    print "add 100,product count="+str(product)
                    self.lock.notify()
                self.lock.release()
                time.sleep(2)

class Cost(threading.Thread):
    def __init__(self,lock):
        self.lock=lock
        super(Cost,self).__init__()

    def run(self):
        global product
        while 1:
            if self.lock.acquire():
                if product<=100:
                    self.lock.wait()
                else:
                    product-=60
                    print "cost 60,product count="+str(product)
                    self.lock.notify()
                self.lock.release()
                time.sleep(1)

def test():
    for i in range(5):
        n=Make(lock)
        n.start()
    for i in range(5):
        m=Cost(lock)
        m.start()
if __name__=="__main__":
    test()