生产者消费者问题python版

#coding=utf-8

'''
Created on 2013年11月13日
生产者与消费者python版
@author: dear_shen
'''
import threading
import Queue
import time
condition = threading.Condition() #设置条件变量

class Producter(threading.Thread):
    def __init__(self,puc_pool,i):
        threading.Thread.__init__(self)
        self.puc_pool = puc_pool
        self.setName("生产者"+str(i))
    def run(self):
        while True:
            if condition.acquire():
                if self.puc_pool.qsize() < 10:
                    print "%s 开始生产产品 %s" % (self.name,self.puc_pool.qsize()+1)
                    self.puc_pool.put(self.name+"-"+str(self.puc_pool.qsize()+1))
                    condition.notify() #唤醒阻塞的线程

                else:
                    print "产品数量多于10个，停止生产，生产者休息！"
                    condition.wait() #阻塞自己

                condition.release()
                time.sleep(1)
class Consumer(threading.Thread):
    def __init__(self,puc_pool,i):
        threading.Thread.__init__(self)
        self.puc_pool = puc_pool
        self.setName("消费者"+str(i))
    def run(self):
        while True:
            if condition.acquire():
                if self.puc_pool.qsize()>0:
                    tem = self.puc_pool.get()
                    print "%s 使用了产品 %s,还剩%s个" % (self.name,tem,self.puc_pool.qsize())
                    self.puc_pool.task_done() #产品队列中减少一个

                    condition.notify()
                else:
                    print "没有产品了，消费者休息！"
                    condition.wait()
                condition.release()
                time.sleep(2)
if __name__ == "__main__":
    print "main begin"
    puc = Queue.Queue()
    for i in range(2):
        p = Producter(puc,i)
        p.setDaemon(True)
        p.start()
    time.sleep(5)
    for i in range(5):
        c = Consumer(puc,i)
        c.setDaemon(True)
        c.start()
    puc.join()#当产品队列为空时候再打印main over，如果注释掉了上面的setDaemon,虽然打印了main over，但是子线程并没有结束。

    print "main over"