创新互联Python教程：python多线程中消息队列如何实现？

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

专注于为中小企业提供成都做网站、网站设计、外贸营销网站建设服务,电脑端+手机端+微信端的三站合一,更高效的管理,为中小企业双牌免费做网站提供优质的服务。我们立足成都，凝聚了一批互联网行业人才，有力地推动了1000+企业的稳健成长，帮助中小企业通过网站建设实现规模扩充和转变。

线程间通信：消息队列

主要方式：

通过变量，直接读写；通过消息队列；

消息队列：

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教程：python多线程中消息队列如何实现？
网页URL：http://www.hantingmc.com/qtweb/news34/544584.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联