线程间通信:消息队列
主要方式:
通过变量,直接读写;通过消息队列;
消息队列:
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
上一篇:css怎么改变文本框颜色