queue队列本身是get阻塞持续等待put,实际应用中需要做出改变;
本代码实现:get阻塞等待put输入,检测到输入后,等待1s持续接收,直到超过1s无新信息;
将收到的信息汇总list,进行打印;
#queue队列本身是get阻塞持续等待put,实际应用中需要做出改变
#本代码实现:get阻塞等待put输入,检测到输入后,等待1s持续接收,直到超过1s无新信息;
import queue
import timeq = queue.Queue()def process_queue():while 1:messages = []messages.append(q.get())while 1:try:#等待2秒,如果取不到数据,则退出messages.append(q.get(timeout=2))except:breakprint(messages)# 假设有一些信息被放入队列中
q.put("Message 1")
q.put("Message 2")
q.put("Message 3")# 处理队列中的信息
process_queue()