#_*_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 1:

             if self.__Queue.full():

                 time.sleep(3)

             else:

                 time.sleep(1)

                 self.__Queue.put('**star**')

                 print '-->%s plus a star' % self.__Name

 class Cunsumer(Thread):

     def __init__(self,name,queue):

         self.__Name = name

         self.__Queue = queue

         super(Cunsumer,self).__init__()

     def run(self):

          while 1:

              if self.__Queue.empty():

                     time.sleep(3)

              else:

                  time.sleep(1)

                  self.__Queue.get()

                  print '-->%s get a star' % self.__Name

 maxque = Queue(maxsize=50)

 P1 = Procuder('p1',maxque)

 P1.start()

 P2 = Procuder('p2',maxque)

 P2.start()

 P3 = Procuder('p3',maxque)

 P3.start()

 for i in range(20):

     print '_________________'

     temp = Cunsumer(i,maxque)

     temp.start()