知行编程网知行编程网  2022-11-18 16:00 知行编程网 隐藏边栏  31 
文章评分 0 次,平均分 0.0
导语: 本文主要介绍了关于python多线程中消息队列如何实现?的相关知识,希望可以帮到处于编程学习途中的小伙伴

如何在python多线程中实现消息队列?


我们在使用多线程时候,有没有听过


术语“消息队列”怎么样?让我从字面上告诉你,排队就是有序的排队。消息必须与传递相关。这样大家在组合的时候就应该知道什么是消息队列了,也就是将接收到的内容按顺序排列。传下去,在大家理解的基础上,阅读以下内容~



线程间通信:消息队列


主要方式:


通过变量,直接读写;通过消息队列;



消息队列:

from queue import Queue


Queue与多进程中的类似,主要方法:



方法说明:

如何在python多线程中实现消息队列?



给大家演示实例:

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



消息队列是我们经常使用的东西,灵活掌握非常重要。如果你正在学习线程,你必须是第一个了解消息队列的人。

~

本文为原创文章,版权归所有,欢迎分享本文,转载请保留出处!

知行编程网
知行编程网 关注:1    粉丝:1
这个人很懒,什么都没写
扫一扫二维码分享