导语:
本文主要介绍了关于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
消息队列是我们经常使用的东西,灵活掌握非常重要。如果你正在学习线程,你必须是第一个了解消息队列的人。
~
本文为原创文章,版权归知行编程网所有,欢迎分享本文,转载请保留出处!
你可能也喜欢
- ♥ 肝了 90 条写 Python 程序的建议02/08
- ♥ 用 Python 制作棘手的小程序11/08
- ♥ Python实现信息熵的计算代码09/05
- ♥ python中pandas的知识点12/17
- ♥ 你的python是什么意思09/19
- ♥ 什么是 python 守护线程12/31
内容反馈