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

2025-12-01 0 15,095

我们在使用多线程时候,有没有听过“消息队列”这个名词呢?先从字面上跟大家说下,队列就是尽然有序的排队,消息,肯定是跟传递有关,这样大家组合起来就应该知道什么是消息队列了吧,那就是把收取的内容进行井然有序的传递下去,在大家理解的基础上,看下文内容吧~

线程间通信:消息队列

主要方式:

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

消息队列:

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

消息队列是我们经常要要用到的,灵活的掌握使用是至关重要的,大家如果正在学习线程,关于消息队列一定是首当其冲要去了解哦~

收藏 (0) 打赏

感谢您的支持,我会继续努力的!

打开微信/支付宝扫一扫,即可进行扫码打赏哦,分享从这里开始,精彩与您同在
点赞 (0)

声明:以上部本文内容由互联网用户自发贡献,本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容,一经查实,本站将立刻删除。投诉邮箱:3758217903@qq.com

ZhiUp资源网 python基础 python多线程中消息队列如何实现? https://www.zhiup.top/3671.html

相关