q=Queue(3)        #可以设置队列中最多可以进入多少个值，也可以不设置

q.put('first')

q.put('second')

q.put('third')

# q.put('fourht')    #当设置最多进入3个值时，第四个值过来时就会卡住，只有当第一值     被取出去的时候，第四个值才会进入

print(q.get())

print(q.get())

print(q.get())

# print(q.get())   #当队列中有三个值，而想去取第四个值的时候，也会卡住，只有队列中进入了第四个值的时候才往下运行

 #生产者消费者模型1

 # from multiprocessing import Process,Queue

 # import time

 # import random

 # import os

 # def consumer(q):

 #     while True:

 #         res=q.get()

 #         if res is None:

 #             break

 #         time.sleep(random.randint(1,3))

 #         print('\033[45m%s 吃了 %s\033[0m' % (os.getpid(), res))

 # def producer(q):

 #     for i in range(5):

 #         time.sleep(2)

 #         res='包子%s' %i

 #         q.put(res)

 #         print('\033[44m%s 制造了 %s\033[0m' %(os.getpid(),res))

 #     q.put(None)

 # if __name__ == '__main__':

 #     q=Queue()

 #     #生产者们：厨师们

 #     p1=Process(target=producer,args=(q,))

 #

 #     #消费者们：吃货们

 #     p2=Process(target=consumer,args=(q,))

 #

 #     p1.start()

 #     p2.start()

 #     p1.join()

 #     p2.join()

 #     print('主')

 # #生产者消费者模型2

 # from multiprocessing import Process,Queue

 # import time

 # import random

 # import os

 # def consumer(q):

 #     while True:

 #         res=q.get()

 #         if res is None:break

 #         time.sleep(random.randint(1,3))

 #         print('\033[45m%s 吃了 %s\033[0m' % (os.getpid(), res))

 #

 # def product_baozi(q):

 #     for i in range(3):

 #         time.sleep(2)

 #         res='包子%s' %i

 #         q.put(res)

 #         print('\033[44m%s 制造了 %s\033[0m' %(os.getpid(),res))

 #

 #

 # def product_gutou(q):

 #     for i in range(3):

 #         time.sleep(2)

 #         res='骨头%s' %i

 #         q.put(res)

 #         print('\033[44m%s 制造了 %s\033[0m' %(os.getpid(),res))

 #

 #

 # def product_ganshui(q):

 #     for i in range(3):

 #         time.sleep(2)

 #         res='泔水%s' %i

 #         q.put(res)

 #         print('\033[44m%s 制造了 %s\033[0m' %(os.getpid(),res))

 # if __name__ == '__main__':

 #     q=Queue()

 #     #生产者们：厨师们

 #     p1=Process(target=product_baozi,args=(q,))

 #     p2=Process(target=product_gutou,args=(q,))

 #     p3=Process(target=product_ganshui,args=(q,))

 #

 #     #消费者们：吃货们

 #     p4=Process(target=consumer,args=(q,))

 #     p5=Process(target=consumer,args=(q,))

 #

 #     # p_l=[p1,p2,p3,p4,p5]

 #     # for p in p_l:

 #     #     p.start()

 #     #

 #     # for p in p_l:

 #     #     p.join()

 #

 #

 #     p1.start()

 #     p2.start()

 #     p3.start()

 #     p4.start()

 #     p5.start()

 #

 #

 #     p1.join()

 #     p2.join()

 #     p3.join()

 #     q.put(None)

 #     q.put(None)

 #     p4.join()

 #     p5.join()

 #

 #     print('主')

 # #生产者消费者模型3

 # from multiprocessing import Process,JoinableQueue

 # import time

 # import random

 # import os

 # def consumer(q):

 #     while True:

 #         res=q.get()

 #         time.sleep(random.randint(1,3))

 #         print('\033[45m%s 吃了 %s\033[0m' % (os.getpid(), res))

 #         q.task_done()

 #

 # def product_baozi(q):

 #     for i in range(5):

 #         time.sleep(2)

 #         res='包子%s' %i

 #         q.put(res)

 #         print('\033[44m%s 制造了 %s\033[0m' %(os.getpid(),res))

 #     q.join()

 #

 # if __name__ == '__main__':

 #     q=JoinableQueue()

 #     #生产者们：厨师们

 #     p1=Process(target=product_baozi,args=(q,))

 #

 #     #消费者们：吃货们

 #     p4=Process(target=consumer,args=(q,))

 #     p4.daemon=True

 #

 #     p1.start()

 #     p4.start()

 #

 #     p1.join()

 #     print('主')

 #     #p2结束了

 #生产者消费者模型4

 from multiprocessing import Process,JoinableQueue

 import time

 import random

 import os

 def consumer(q):

     while True:

         res=q.get()

         time.sleep(random.randint(1,3))

         print('\033[45m%s 吃了 %s\033[0m' % (os.getpid(), res))

         q.task_done()

 def product_baozi(q):

     for i in range(3):

         time.sleep(2)

         res='包子%s' %i

         q.put(res)

         print('\033[44m%s 制造了 %s\033[0m' %(os.getpid(),res))

     q.join()

 def product_gutou(q):

     for i in range(3):

         time.sleep(2)

         res='骨头%s' %i

         q.put(res)

         print('\033[44m%s 制造了 %s\033[0m' %(os.getpid(),res))

     q.join()

 def product_ganshui(q):

     for i in range(3):

         time.sleep(2)

         res='泔水%s' %i

         q.put(res)

         print('\033[44m%s 制造了 %s\033[0m' %(os.getpid(),res))

     q.join()

 if __name__ == '__main__':

     q=JoinableQueue()

     #生产者们：厨师们

     p1=Process(target=product_baozi,args=(q,))

     p2=Process(target=product_gutou,args=(q,))

     p3=Process(target=product_ganshui,args=(q,))

     #消费者们：吃货们

     p4=Process(target=consumer,args=(q,))

     p5=Process(target=consumer,args=(q,))

     p4.daemon=True

     p5.daemon=True

     p_l=[p1,p2,p3,p4,p5]

     for p in p_l:

         p.start()

     p1.join()

     p2.join()

     p3.join()

     print('主')