python 生产者与消费者模型

import time
import random
from multiprocessing import Process
from multiprocessing import Queue

def consumer(q,name):
    while True:
        f = q.get()
        if f == None: break    # 解决方法之一（比较笨）
        time.sleep(random.randint(1, 3))
        print(‘\033[32m{}吃了{}\033[0m‘.format(name,f))

def producer(q,name,food):
    for i in range(3):
        time.sleep(random.randint(1,3))
        f = ‘{}生产了{}{}‘.format(name,food,i)   # 数据
        print(f)
        q.put(f)   # 往队列中添加数据
    q.put(None)   # 解决方法之一（比较笨）

if __name__ == ‘__main__‘:
    q = Queue()
    p = Process(target=producer,args=(q,‘admin‘,‘馒头‘))
    c = Process(target=consumer,args=(q,‘xp‘))
    p.start()
    c.start()
# 问题来了，生产者，队列中没有数据后，消费者一直处于阻塞状态，怎么解决？

import time
import random
from multiprocessing import Process
from multiprocessing import JoinableQueue

def consumer(q,name):
    while True:
        f1 = q.get()
        print(‘\033[32m{}吃了{}\033[0m‘.format(name,f1))
        time.sleep(random.randint(1, 3))
        q.task_done()
#
#
def producer(q,name,food):
    for i in range(10):
        time.sleep(random.randint(1,3))
        f = ‘{}生产了{}{}‘.format(name,food,i)
        q.put(f)
        print(f)
    q.join()

if __name__ == ‘__main__‘:
    q = JoinableQueue()
    p1 = Process(target=producer,args=(q,‘admin‘,‘面条‘))
    c = Process(target=consumer,args=(q,‘xp‘))
    c.daemon = True
    p1.start()
    c.start()
    p1.join()