Python线程安全队列Queue详解：基础操作与多线程验证

周末不加班

发布时间：2026-10-15 | 4人浏览过

原创

本文深入解析Python中queue模块的Queue类，详细演示其入队、出队及状态查询等基础操作方法。通过多线程并发读写测试，验证Queue在高频交互下的线程安全性，展示其如何保证数据一致性，为并发编程提供可靠的数据结构支持。

一、什么是队列？

队列的概念类似于现实生活中的排队现象，元素按照进入的顺序依次排列，新元素从队尾加入，旧元素从队头移除。

在Python中，Queue类位于内置模块queue中，专门用于处理这种先进先出（FIFO）的数据结构。

import queue
q = queue.Queue(5) #可以传入参数指定队列大小
queue.Queue()# 不传或者给0或者<0的数字则创建一个无限长度的队列

该模块提供了多种实用方法，其中以下方法在日常开发中使用频率最高：

get方法：用于获取并移除队头元素，即执行出队操作。
put方法：用于将元素添加到队列末尾，即执行入队操作。
qsize方法：用于获取当前队列中元素的总数量。
empty方法：用于判断队列是否已清空，即检查是否为空状态。
full方法：用于判断队列是否已满，即检查是否达到容量上限。

为了更直观地理解，这里通过图示展示队列的工作流程：

示例中执行了三次put操作，依次存入“持续学习”、“持续开发”和“我雷学委”，此时队列长度显示为3。

二、队列基操入队/出队/查队列状态

以下是演示队列基本功能的具体代码实现：

import queue

q = queue.Queue(5)

print("学委粉丝队列：", q)
print("空队，学委粉丝队列大小：", q.qsize())
print("空队列？", q.empty())
for i in range(5):
    q.put(i)

print("队列满了？", q.full())
print("排满了，学委粉丝队列大小：", q.qsize())

while not q.empty():
    print("粉丝 %s 出队点赞！" % q.get())
print("最后，学委粉丝队列大小：", q.qsize())

该代码片段初始化了一个最大容量为5的队列实例。

随后通过循环将队列填满，接着依次执行出队操作，模拟粉丝出队点赞的过程。

程序的运行输出效果如下所示：

整个过程逻辑清晰，操作简便。

三、Queue是一个线程安全的类

在前面的多线程文章中，我们观察到直接反复读写共享变量时，结果往往不可预测且存在竞争条件。

amount = 100
def transfer(money):
    global amount
    for i in range(100000):
        amount += money

那么，如果对Queue进行反复的读写操作，是否也会出现类似的数据不一致问题呢？

我们可以编写一段测试代码来验证其线程安全性：

import queue
import threading

xuewei_fans_q = queue.Queue()


def transfer(money):
    for i in range(100000):
        xuewei_fans_q.put(money)
        xuewei_fans_q.get()


# 创建4个任务重复给学委加关注/脱粉（还是希望各位编程的明日之星跟着学习，共同进步！）
t_group = []
for i in range(10):
    t = threading.Thread(target=lambda: transfer(-1))
    t_group.append(t)
    t.start()
    t = threading.Thread(target=lambda: transfer(1))
    t_group.append(t)
    t.start()
    t = threading.Thread(target=lambda: transfer(-1))
    t_group.append(t)
    t.start()
    t = threading.Thread(target=lambda: transfer(1))
    t_group.append(t)
    t.start()

for t in t_group:
    t.join()
print("-" * 16)
print("活跃线程数:", threading.active_count())
print("活跃线程:", threading.current_thread().name)
#反复对队列进行添加数据，移除数据，队列最后清零了
print("学委粉丝队列:", xuewei_fans_q.qsize())

无论运行多少次，队列最终的元素数量始终保持在0，证明了其内部机制的有效性。

总结：本文介绍了Python中线程安全的Queue类，这是一个在并发编程中至关重要的组件。经过实际代码验证，Queue类确实具备线程安全特性，能够安全地处理多线程环境下的数据共享。

到此这篇关于Python线程之线程安全的队列的文章就介绍到这了,更多相关Python线程安全队列内容请搜索本站以前的文章或继续浏览下面的相关文章希望大家以后多多支持本站！