首页 > 文章 > python教程

Python多线程Queue使用教程

时间：2025-11-19 12:37:21 257浏览收藏

golang学习网今天将给大家带来《Python多线程Queue通信详解》，感兴趣的朋友请继续看下去吧！以下内容将会涉及到等等知识点，如果你是正在学习文章或者已经是大佬级别了，都非常欢迎也希望大家都能给我建议评论哈~希望能帮助到大家！

Queue是Python中线程和进程间通信的关键工具，queue.Queue用于线程间安全数据传递，multiprocessing.Queue支持跨进程通信，具备阻塞、序列化传输和任务同步特性，结合JoinableQueue等类型可有效管理并发任务流程。

python中Queue如何通信

在Python中，Queue 是实现线程间或进程间通信的重要工具。它提供了线程安全和进程安全的数据交换方式，常用于多线程编程或多进程编程中的数据传递。

Queue在多线程中通信

在同一个进程中，多个线程可以共享内存，使用 queue.Queue 可以安全地在线程之间传递数据，避免竞争条件。

特点：

线程安全：内部加锁机制保证同一时间只有一个线程操作队列
支持阻塞操作：put() 和 get() 可设置超时或阻塞等待

示例：

from queue import Queue
import threading

def producer(q):
for i in range(3):
q.put(f"data-{i}")
print(f"Produced: data-{i}")

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

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

t1.start()
t2.start()
t1.join()
q.put(None) # 发送结束信号
t2.join()

Queue在多进程中通信

不同进程不共享内存，需使用专门的进程安全队列。Python 提供了 multiprocessing.Queue 来实现跨进程通信。

特点：

支持跨进程数据传递
可传输任意可序列化对象（通过pickle）
底层使用管道和锁机制确保安全

示例：

from multiprocessing import Process, Queue

def worker(q):
q.put("Hello from child process")

if __name__ == "__main__":
q = Queue()
p = Process(target=worker, args=(q,))
p.start()
print(q.get()) # 主进程接收数据
p.join()

其他类型的Queue

除了基本队列，multiprocessing 还提供两种高级队列：

Pipe：双向通信，性能更高但接口较简单
JoinableQueue：支持 task_done() 和 join()，适合任务调度

例如使用 JoinableQueue 控制工作流程：

from multiprocessing import Process, JoinableQueue

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

if __name__ == "__main__":
q = JoinableQueue()
pw = Process(target=worker, args=(q,))
pw.start()

for i in range(3):
q.put(i)

q.join() # 等待所有任务完成
q.put(None) # 结束信号
pw.join()

基本上就这些。根据场景选择合适的 Queue 类型，能有效解决线程或进程间的通信问题。注意在多进程环境下要避免共享普通变量，优先使用 Queue 传递数据。不复杂但容易忽略的是：记得在适当时候关闭或终止队列，防止程序挂起。

今天关于《Python多线程Queue使用教程》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！