生产者消费者模型

#!/usr/bin/env python
# coding:utf-8
from threading import Thread
from Queue import Queue
import time 




class Procuder(Thread):
    def __init__(self,name,queue):
        self.__Name = name
        self.__Queue = queue #容器
        super(Procuder,self).__init__() #执行父类构造函数
    def run(self):
        while True:
            if self.__Queue.full():
                time.sleep(1)
            else:
                self.__Queue.put('商品')
                time.sleep(1)
                print '%s 生产了一个商品' %(self.__Name,)            
            
            
        #Thread.run(self)

class Consumer(Thread):
    
    def __init__(self,name,queue):
        self.__Name = name
        self.__Queue = queue #容器
        super(Consumer,self).__init__() #执行父类构造函数
    def run(self):
        while True:
            if self.__Queue.empty():
                time.sleep(1)
            else:
                self.__Queue.get()
                time.sleep(1)
                print '%s 消费了一个商品' %(self.__Name,)
que = Queue(maxsize=100)

Dylan1 = Procuder('Dylan1',que)
Dylan1.start()
Dylan2 = Procuder('Dylan2',que)
Dylan2.start()
Dylan3 = Procuder('Dylan3',que)
Dylan3.start()

for item in range(20):
    name = 'Elaine%d' %(item,)
    Elaine = Consumer(name,que)
    Elaine.start()