主要内容：

• 小目标：掌握进程间通信方式
• 主要内容：消息队列

一个问题：父子进程之间变量不共享，他们之间如何进行通信？

1. 消息队列

消息队列相关方法 消息队列是进程间通信的一张方式，它基于系统提供的机制实现；

使用方式：from multiprocessing import Queue

方法说明：

消息队列

注意：消息入队与出队默认阻塞模式，可以设置超时或者非阻塞模式；

2. 一个例子：

需求：

代码实现：

import multiprocessingfrom multiprocessing import Queue#进程函数def func(msgq):    while True:        msg = msgq.get()        if msg == 'q':            break        print(\"sub process receive msg:\", msg)if __name__ == \"__main__\":    #全局消息队列    main_msgq = Queue()    #消息队列必须通过参数传入到子进程，否则无效    p = (target=func, args=(main_msgq,))    p.start()    while True:        #读取输入        val = input('input :')        #插入消息        main_msgq.put(val)        if val == 'q':            break    p.join()

结果：

input :1input :sub process receive msg: 12sub process receive msg: 2input :3sub process receive msg: 3input :q

注意点：消息队列必须通过参数传递给子进程，否则不生效；

3. 阻塞与非阻塞方式：

3.1 设置阻塞模式

• 例1：消息入队

#消息队列数量为2msgq = Queue(maxsize=2)#放入两条消息msgq.put('1')msgq.put('2')#判断fullprint(())#插入一条，一直阻塞msgq.put('3')print(\"end\")

结果：一直阻塞，直到队列有空位置；

• 例2： 消息出队

msgq = Queue(maxsize=2)print(())msgq.get()print('over')

结果：一直阻塞，直到有消息；

3.2 设置超时

例3：消息入队设置超时

#消息队列数量为2msgq = Queue(maxsize=2)#放入两条消息msgq.put('1')msgq.put('2')#判断fullprint(())#插入一条，一直阻塞msgq.put('3', timeout=1)print(\"ove\")

结果：超时异常；

对应读取消息：msgq.get(timeout=1)

3.3 设置非阻塞模式

#消息队列数量为2msgq = Queue(maxsize=2)#放入两条消息msgq.put('1')msgq.put('2')#判断fullprint(())msgq.put('3', block=False)print(\"ove\")

结果：消息队列full之后，直接写入消息，报异常；

总结：

文章来源：《信息通信技术与政策》 网址: http://www.xxtxzz.cn/zonghexinwen/2020/0817/603.html