python多线程生产消费

#!/usr/bin/env python
# -*- coding: utf-8 -*-


from threading import Thread
from Queue import  Queue
import time

class Producer(Thread):

def __init__(self,name,queue):
self.__name = name
self.__queue = queue
super(Producer,self).__init__()

def run(self):
while 1:
if self.__queue.full():
                time.sleep(1)
else:
self.__queue.put('bread')
                time.sleep(1)
print '%s produce a bread' %(self.__name,)



class Consumer(Thread):

def __init__(self,name,queue):
self.__name = name
self.__queue = queue
super(Consumer,self).__init__()

def run(self):
while 1:
if self.__queue.empty():
                time.sleep(1)
else:
self.__queue.get()
                time.sleep(1)
print '%s eat a bread' % (self.__name,)

que = Queue(maxsize=100)

for p in range(3):
    name = 'P%d' % (p,)
    temp = Producer(name, que)
    temp.start()

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