python多线程queue使用方法

在Python中，`Queue`（也称为`multiprocessing.Queue`，属于`concurrent.futures`模块的一部分，当使用`threading`模块时则直接从`queue`模块导入）是一个用于在进程之间共享数据的重要工具，特别是在多线程环境中。它的基本使用步骤如下：

1. 导入Queue模块：

from queue import Queue

2. 创建Queue实例：

q = Queue()

3. 放入元素（put）：

q.put('Element 1')
q.put(42)

4. 提取元素（get）：

value = q.get()  # 阻塞直到队列中有值

5. 可选：设置最大长度（maxsize）：

q = Queue(maxsize=10)  # 设置队列最大容量为10

6. 处理任务（例如，可以创建一个线程消费队列内容）：

def worker():
    while True:
        task = q.get()
        if task is None:  # 消费完后设置结束信号
            break
        process_task(task)

# 创建并启动工作线程
worker_thread = threading.Thread(target=worker)
worker_thread.start()

7. 结束信号（通常在主线程中发送）：

q.put(None)  # 通知工作线程停止
worker_thread.join()  # 等待工作线程结束