#由于进程之间是不共享全局变量的,所以这个时候我们需要一个东西来解决进程之间的通信问题
#Queue的导入就可以解决通信问题,按照上图代码可知一些信息,
1. 我们先看主函数,首先创建进程的消息队列为4(可以接收4个数据)
2. 然后创建两个进程,并且给上面的函数传入参数queue(注意:单个参数需要加逗号,这是元组)
3. 创建work函数 ,for循环添加数据到消息队列queue(if queue.full() 判断队列是否已满)
4. 创建work1函数,建立死循环对消息队列取值(if queue.empty() 判断队列是否为空)
5. 进行之后可以发现,两个进程的通信问题可以这样解决
#总结:进程之间不共享全局变量,利用Queue来解决进程之间的通信问题,同时的进程下可以运行多个线程!
扩展;
1. 消息队列里可以放入任意数据类型
2. result = queue.qsize() 获取当前队列消息个数
网友评论