当前位置: 首页 > 图灵资讯 > 行业资讯> python多线程中消息队列如何实现?

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

来源:图灵python
时间: 2024-11-13 16:37:21

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

线程间通信:消息队列

主要方式:

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

消息队列:

fromqueueimportQueue

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

方法说明:

给大家演示实例:

importthreading
fromqueueimportQueue
#消息队列
msgq=Queue()

defrecvmsg(*args,**kwargs):
#线程函数,接受消息
whileTrue:
msg=msgq.get()
print('revmsg:',msg)
ifmsg=='q':
break

defsendmsg():
#发送消息
whileTrue:
msg=input('enter:')
msgq.put(msg)
ifmsg=='q':
break

if__name__=='__main__':
#创建线程
t1=threading.Thread(target=recvmsg)
t1.start()
sendmsg()
t1.join()

结果:

enter:1
revmsg:1
enter:2
revmsg:2
enter:3
revmsg:3
enter:q
revmsg:q

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