目标:
1:利用Queue(消息队列)实现进程池内多个进程间的通信
2:掌握异步工作方式的wait()方法
一:进程池内进程间的通信
通信原理:利用进程池内创建的Queue(队列)来实现进程池内进程间的通信
进程池内创建队列方法:pool_queue = multiprocessing.Manager().Queue(3) 【创建一个长度为3的线程池队列】
注意事项:
1:在进程池中创建队列,一定要用multiprocessing模块内的Manager()类里面的Queue()类来创建!
2:在采用异步方法实现进程池中进程的通信时,不要在最后忘记close()方法和join()方法
通信图示
快速代码体验(同步):
异步【重点】: