创建一个最多容纳 10 个元素的队列

q = Queue(maxsize=10)

出队 get()

item = q.get()
print(item) # 输出: item1

查看队列是否为空

print(q.empty()) # 队列空时返回 True

查看队列是否已满（如果设置了 maxsize）

print(q.full()) # 容量满时返回 True

查看当前队列大小

print(q.qsize())

def producer(q):
for i in range(3):
q.put(f"任务-{i}")
print(f"生产: 任务-{i}")
time.sleep(1)

def consumer(q):
while True:
item = q.get()
if item is None:
break
print(f"消费: {item}")
q.task_done()

q = Queue()
t1 = threading.Thread(target=producer, args=(q,))
t2 = threading.Thread(target=consumer, args=(q,), daemon=True)

t1.start()
t2.start()
t1.join()

q.put(None) # 发送结束信号