#生产者消费者模型import timefrom multiprocessing import Process,Queue,JoinableQueuedef 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('主进程结束')