python 队列长度

import queue

# 创建一个队列
q = queue.Queue()

# 添加元素到队列
for i in range(5):
    q.put(i)

# 获取队列长度
length = q.qsize()
print(f"Queue length: {length}")

from collections import deque

# 创建一个deque
dq = deque()

# 添加元素到deque
for i in range(5):
    dq.append(i)

# 获取deque长度
length = len(dq)
print(f"Deque length: {length}")

import queue
import threading

q = queue.Queue()
lock = threading.Lock()

def worker():
    while True:
        item = q.get()
        if item is None:
            break
        # 处理item
        with lock:
            print(f"Queue length inside worker: {q.qsize()}")
        q.task_done()

# 启动多个工作线程
threads = []
for i in range(4):
    t = threading.Thread(target=worker)
    t.start()
    threads.append(t)

# 添加任务到队列
for item in range(10):
    q.put(item)

# 等待所有任务完成
q.join()

# 停止工作线程
for i in range(4):
    q.put(None)
for t in threads:
    t.join()