1.队列是先进先出的模型
import queue q = queue.Queue() q.put(123) q.task_done() q.join() print (q.get())
q.join()跟q.task_done()要联合起来使用。q.join()只有前面的动作完成了之后后面的动作才能执行,譬如上面的例子,如果注释掉q.task_done,那么对于通道的操作是不能被捕获的,所以就一直不会执行q.join()后面的操作了。
只有当每一次的put都有一个返回给通道的值得时候,q.join()获取到该消息,然后可以取出其中的部分消息
import queue q = queue.Queue() q.put(123) q.task_done() q.put(456) q.task_done() q.put(456) q.task_done() print (q._qsize()) q.join() print (q.get())
时间: 2024-11-03 04:51:10