import _thread
from queue import Queue
# 初始化队列
q = Queue(maxsize=100)
def get():
    while True:
        # q.get 会阻塞等待消息过来每当有q.put执行完后 q.get会受到相关信号,解除阻塞往下执行
        item = q.get()
        print(item)
# 开启线程在哪等待消息
_thread.start_new_thread(get,())
# put消息到队列
q.put(1)
q.put(2)