Python 再次改进版通过队列实现一个生产者消费者模型

Posted 缥缈映苍穹

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Python 再次改进版通过队列实现一个生产者消费者模型相关的知识,希望对你有一定的参考价值。

import time
from multiprocessing import Process,Queue
#生产者
def producer(q):
    for i in range(10):
        time.sleep(0.2)
        s = 大包子%s号%i
        print(s+新鲜出炉,拿去用)
        q.put(s)
    q.put(None)  #发送一个任务结束信号,来中断消费者的程序

def consumer(q):
    while 1:
        time.sleep(0.5)
        baozi = q.get()
        if baozi == None:
            print(都吃完了大哥,该回家伺候嫂子了)
            break
        print(baozi+被吃了)

if __name__ == __main__:
    q = Queue(30)

    pro_p = Process(target=producer,args=(q,))
    con_p = Process(target=consumer,args=(q,))
    pro_p.start()
    con_p.start()

 

以上是关于Python 再次改进版通过队列实现一个生产者消费者模型的主要内容,如果未能解决你的问题,请参考以下文章