先入先出队列:
import queue q = queue.Queue(10) # 10为队列长度 for i in range(5): q.put(i, block=False) # block=False为非阻塞,默认为阻塞 print(q.qsize()) # 队列元素个数 q.put('hehe', timeout=2) # 超时时间为2秒 print(q.full()) # 判断队列是否满了 print(q.maxsize) # 队列最大个数 while not q.empty(): # 队列是否为空,不为空就取数据 print(q.get()) # get时也是默认阻塞的,其他参数与put相同 q.task_done() # 阻塞进程,当队列中任务执行完毕后,不再阻塞。表示任务执行完毕 q.join()