【python】初学者

进程之间的通信(queue)

2018-05-20  本文已影响21人  米兰的小铁匠
上部分代码 主函数部分

#由于进程之间是不共享全局变量的,所以这个时候我们需要一个东西来解决进程之间的通信问题

#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() 获取当前队列消息个数

上一篇下一篇

猜你喜欢

热点阅读