python多线程中消息队列怎么实现-创新互联-成都创新互联网站建设

关于创新互联

多方位宣传企业产品与服务 突出企业形象

公司简介 公司的服务 荣誉资质 新闻动态 联系我们

python多线程中消息队列怎么实现-创新互联

这篇文章主要介绍了python多线程中消息队列怎么实现,具有一定借鉴价值,需要的朋友可以参考下。希望大家阅读完这篇文章后大有收获。下面让小编带着大家一起了解一下。

创新互联专注于企业成都营销网站建设、网站重做改版、华州网站定制设计、自适应品牌网站建设、H5场景定制成都商城网站开发、集团公司官网建设、外贸网站建设、高端网站制作、响应式网页设计等建站业务,价格优惠性价比高,为华州等各大城市提供网站开发制作服务。

线程间通信:消息队列

主要方式:

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

消息队列:

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

感谢你能够认真阅读完这篇文章,希望小编分享python多线程中消息队列怎么实现内容对大家有帮助,同时也希望大家多多支持创新互联网站建设公司,,关注创新互联行业资讯频道,遇到问题就找创新互联网站建设公司,,详细的解决方法等着你来学习!


网页题目:python多线程中消息队列怎么实现-创新互联
网址分享:http://kswsj.cn/article/dodehi.html

其他资讯