我们在使用多线程时候,有没有听过“消息队列”这个名词呢?先从字面上跟大家说下,队列就是尽然有序的排队,消息,肯定是跟传递有关,这样大家组合起来就应该知道什么是消息队列了吧,那就是把收取的内容进行井然有序的传递下去,在大家理解的基础上,看下文内容吧~
线程间通信:消息队列
主要方式:
通过变量,直接读写;通过消息队列;
消息队列:
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
消息队列是我们经常要要用到的,灵活的掌握使用是至关重要的,大家如果正在学习线程,关于消息队列一定是首当其冲要去了解哦~