扫二维码与项目经理沟通
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
这篇文章主要介绍了python多线程中消息队列怎么实现，具有一定借鉴价值，需要的朋友可以参考下。希望大家阅读完这篇文章后大有收获。下面让小编带着大家一起了解一下。
线程间通信：消息队列
主要方式：
通过变量，直接读写；通过消息队列；
消息队列：
from queue import Queue
Queue与多进程中的类似，主要方法：
方法说明：
给大家演示实例：
import threading
from queue import Queue
#消息队列
msgq = Queue()
def recvmsg(*args, **kwargs):
#线程函数，接受消息
while True:
msg = msgq.get()
print('rev msg:', msg)
if msg == 'q':
break
def sendmsg():
#发送消息
while True:
msg = input('enter:')
msgq.put(msg)
if msg == 'q':
break
if __name__ == '__main__':
#创建线程
t1 = threading.Thread(target=recvmsg)
t1.start()
sendmsg()
t1.join()结果：
enter:1 rev msg: 1 enter:2 rev msg: 2 enter:3 rev msg: 3 enter:q rev msg: q
感谢你能够认真阅读完这篇文章，希望小编分享python多线程中消息队列怎么实现内容对大家有帮助，同时也希望大家多多支持创新互联网站建设公司，，关注创新互联行业资讯频道，遇到问题就找创新互联网站建设公司，，详细的解决方法等着你来学习!
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
微信二维码
移动版官网