消费者模型代码

Posted 2021-01-16 presleyren

#生产者消费者模型
import time
from multiprocessing import Process,Queue,JoinableQueue

def producer(q):
    for i in range(1,11):
        time.sleep(0.5)
        print(‘生产了包子%s号‘ % i)
        q.put(i)
    q.join()
    print(‘在这里等你‘)
def consumer(q):
    while 1:
        time.sleep(1)
        s = q.get()
        print(‘消费者吃了%s包子‘ % s)
        q.task_done()  #给q对象发送一个任务结束的信号

if __name__ == ‘__main__‘:
    #通过队列来模拟缓冲区,大小设置为20
    q = JoinableQueue(20)
    #生产者进程
    pro_p = Process(target=producer,args=(q,))
    pro_p.start()
    #消费者进程
    con_p = Process(target=consumer,args=(q,))
    con_p.daemon = True #
    con_p.start()
    pro_p.join()
    print(‘主进程结束‘)