介绍

  • 支持不同线程中消息的传递
  • 阻塞实现, 支持多线程的put ,get 原子操作

创建队列对象

  1. from queue import Queue
  2. q = Queue(maxsize=100)
  • 队列最大长度,默认值100

入队列

  1. q.put(item)
  • 返回值
    • True: 成功
    • False: 失败

出队列

  • 会阻塞等待, get每次有put数据get会收到通知
  1. q.get()