生产者消费者模型

时间：2017-09-23 20:26:21 阅读：164 评论：0 收藏：0 [点我收藏+]

标签：roc font odi create 等待队列 ice col queue es2017

生产者消费者模型是接着上一篇：进程来写的，前面的都是基础，

生产者消费者模型是对前面知道的应用：

先看代码：

#!/usr/bin/env python
#coding:utf-8
#Created by Andy @ 2017/9/20


import time, os, random
from multiprocessing import JoinableQueue,Process

def produce_bread(q):
    for i in range(1,5):
        time.sleep(2)
        res = "第%s个bread" % i
        q.put(res)
        print("%s制造了%s面包" % (os.getpid(), res))
    q.join()


def produce_noodle(q):
    for i in range(1,3):
        time.sleep(3)
        res = "第%s碗noodle" % i
        q.put(res)
        print("%s制造了%s面条" %(os.getpid(), res))
    q.join()

def produce_rice(q):
    for i in range(1,6):
        time.sleep(4)
        res = "第%s 碗米饭" % i
        q.put(res)
        print("%s制造了%s" %(os.getpid(), res))
    q.join()

def consumer(q):
    while True:
        res = q.get()
        time.sleep(random.randint(2,5))
        print( "\033[44m%s吃了%s\033[0m"%(os.getpid(),res))
        q.task_done()


if __name__ == "__main__":
    q = JoinableQueue()

    p1 = Process(target=produce_rice, args=(q,))
    p2 = Process(target=produce_bread, args=(q,))
    p3 = Process(target=produce_noodle, args=(q,))

    c1 = Process(target=consumer, args=(q,))
    c2 = Process(target=consumer, args=(q,))
    c1.daemon = True
    c2.daemon = True

    p1.start()
    p2.start()
    p3.start()

    c1.start()
    c2.start()

    p1.join()
    p2.join()
    p3.join()

    print("Finish!")

技术分享