python thread使用queue代码示例

下面是一个使用 Python 的 threading 和 queue 模块的示例代码：

import threading
import queue

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

# 定义一个工作线程
def worker():
    while True:
        # 从队列中获取任务
        task = q.get()

        # 处理任务
        print(f"Processing task: {task}")

        # 标记任务完成
        q.task_done()

# 创建多个工作线程
for i in range(5):
    t = threading.Thread(target=worker)
    t.daemon = True
    t.start()

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

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

print("All tasks are done!")

上述代码创建了一个队列 `q`，然后定义了一个工作线程 `worker`，用于处理队列中的任务。接着创建了多个工作线程，并添加了一些任务到队列中。最后等待所有任务完成。