from multiprocessing import Queue

 q = Queue(5) #队列的大小

 q.put(1) #放入内容

 q.put(2) #放入内容

 q.put(3) #放入内容

 q.put(4) #放入内容

 q.put(5) #放入内容

 print(q.full()) #你的队列是否满了

 print(q.get()) #取出队列中目前排在最前面的数

 q.empty() #判断队列是否为空

 from multiprocessing import Queue,Process

 def produce(q):

     q.put('hello')

 def consume(q):

     print(q.get())

 if __name__ == '__main__':

     q = Queue()

     p = Process(target=produce,args=(q,))

     p.start()

     c = Process(target=consume, args=(q,))

     c.start()

 # 队列

 # 生产者消费者模型

 # 生产者 进程

 # 消费者 进程

 import time

 import random

 from multiprocessing import Process,Queue

 def consumer(q,name):

     while True:

         food = q.get()

         if food is None:

             print('%s获取到了一个空'%name)

             break

         print('\033[31m%s消费了%s\033[0m' % (name,food))

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

 def producer(name,food,q):

     for i in range(4):

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

         f = '%s生产了%s%s'%(name,food,i)

         print(f)

         q.put(f)

 if __name__  == '__main__':

     q = Queue(20)

     p1 = Process(target=producer,args=('Egon','包子',q))

     p2 = Process(target=producer, args=('wusir','泔水', q))

     c1 = Process(target=consumer, args=(q,'alex'))

     c2 = Process(target=consumer, args=(q,'jinboss'))

     p1.start()

     p2.start()

     c1.start()

     c2.start()

     p1.join()

     p2.join()

     q.put(None)

     q.put(None)

 import time

 import random

 from multiprocessing import Process,JoinableQueue

 def consumer(q,name):

     while True:

         food = q.get()

         print('\033[31m%s消费了%s\033[0m' % (name,food))

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

         q.task_done()     # count - 1

 def producer(name,food,q):

     for i in range(4):

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

         f = '%s生产了%s%s'%(name,food,i)

         print(f)

         q.put(f)

     q.join()    # 阻塞  直到一个队列中的所有数据 全部被处理完毕

 if __name__  == '__main__':

     q = JoinableQueue(20)

     p1 = Process(target=producer,args=('Egon','包子',q))

     p2 = Process(target=producer, args=('wusir','泔水', q))

     c1 = Process(target=consumer, args=(q,'alex'))

     c2 = Process(target=consumer, args=(q,'jinboss'))

     p1.start()

     p2.start()

     c1.daemon = True   # 设置为守护进程 主进程中的代码执行完毕之后,子进程自动结束

     c2.daemon = True

     c1.start()

     c2.start()

     p1.join()

     p2.join()      # 感知一个进程的结束

 #  在消费者这一端:

     # 每次获取一个数据

     # 处理一个数据

     # 发送一个记号 : 标志一个数据被处理成功

 # 在生产者这一端:

     # 每一次生产一个数据,

     # 且每一次生产的数据都放在队列中

     # 在队列中刻上一个记号

     # 当生产者全部生产完毕之后,

     # join信号 : 已经停止生产数据了

                 # 且要等待之前被刻上的记号都被消费完

                 # 当数据都被处理完时,join阻塞结束

 # consumer 中把所有的任务消耗完

 # producer 端 的 join感知到,停止阻塞

 # 所有的producer进程结束

 # 主进程中的p.join结束

 # 主进程中代码结束

 # 守护进程(消费者的进程)结束