Python中的队列(Queue)功能及其实际操作指南
最编程
2024-07-25 22:34:03
...
作用:
解耦:
使程序直接实现松耦合,修改一个函数,不会有串联关系。
提高处理效率:FIFO = 现进先出,LIFO = 后入先出。队列:
队列可以并发的派多个线程,对排列的线程处理,并切每个需要处理线程只需要将请求的数据放入队列容器的内存中,线程不需要等待,当排列完毕处理完数据后,线程在准时来取数据即可。请求数据的线程只与这个队列容器存在关系,处理数据的线程down
掉不会影响到请求数据的线程,队列会派给其他线程处理这分数据,它实现了解耦,提高效率。队列内会有一个有顺序的容器,列表与这个容器是有区别的,列表中数据虽然是排列的,但数据被取走后还会保留,而队列中这个容器的数据被取后将不会保留。当必须在多个线程之间安全地交换信息时,队列在线程编程中特别有用。
多线程尽量使用Queue
而不是使用列表(list
),因为列表的pop()
和push()
效果看起来和和Queue的队列、栈一样,但list
不是线程安全的
Python四种类型的队例:
Queue
:FIFO 即first in first out 先进先出LifoQueue
:LIFO 即last in first out 后进先出PriorityQueue
:优先队列,级别越低,越优先deque
:双边队列
导入三种队列
from queue import Queue,LifoQueue,PriorityQueue
Queue 先进先出队列:
常用方法:
-
Queue.qsize()
返回队列的大小 -
Queue.empty()
如果队列为空,返回True
,反之False
-
Queue.full()
如果队列满了,返回True
,反之False
,Queue.full
与maxsize
大小对应 -
Queue.get([block[, timeout]])
获取队列,timeout
等待时间 -
Queue.get_nowait()
相当于Queue.get(False)
,非阻塞方法Queue.put(item)
写入队列,timeout
等待时间 -
Queue.task_done()
在完成一项工作之后,Queue.task_done()
函数向任务已经完成的队列发送一个信号。每个get()
调用得到一个任务,接下来task_done()
调用告诉队列该任务已经处理完毕。 -
Queue.join()
实际上意味着等到队列为空,再执行别的操作
#基本FIFO队列 先进先出 FIFO即First in First Out,先进先出
#maxsize设置队列中,数据上限,小于或等于0则不限制,容器中大于这个数则阻塞,直到队列中的数据被消掉
q = Queue(maxsize=0)
#写入队列数据
q.put(0)
q.put(1)
q.put(2)
#输出当前队列所有数据
print(q.queue)
#删除队列数据,并返回该数据
q.get()
#输也所有队列数据
print(q.queue)
# 输出:
# deque([0, 1, 2])
# deque([1, 2])
LifoOueue 后进先出队列:
#LIFO即Last in First Out,后进先出。与栈的类似,使用也很简单,maxsize用法同上
lq = LifoQueue(maxsize=0)
#队列写入数据
lq.put(0)
lq.put(1)
lq.put(2)
#输出队列所有数据
print(lq.queue)
#删除队尾数据,并返回该数据
lq.get()
#输出队列所有数据
print(lq.queue)
#输出:
# [0, 1, 2]
# [0, 1]
优先队列:
# 存储数据时可设置优先级的队列
# 优先级设置数越小等级越高
pq = PriorityQueue(maxsize=0)
#写入队列,设置优先级
pq.put((9,'a'))
pq.put((7,'c'))
pq.put((1,'d'))
#输出队例全部数据
print(pq.queue)
#取队例数据,可以看到,是按优先级取的。
pq.get()
pq.get()
print(pq.queue)#输出:[(9, 'a')]
双边队列:
#双边队列
dq = deque(['a','b'])
#增加数据到队尾
dq.append('c')
#增加数据到队左
dq.appendleft('d')
#输出队列所有数据
print(dq)
#移除队尾,并返回
print(dq.pop())
#移除队左,并返回
print(dq.popleft())#输出:deque(['d', 'a', 'b', 'c'])cd
推荐阅读
-
STL 中的 Priority_queue - 深入分析 C++ 中优先队列的实现原理、核心功能和基本机制。
-
【2022新手指南】Java编程进阶之路 - 六、技术架构篇 ### MySQL索引底层解析与优化实战 - 你会讲解MySQL索引的数据结构吗?性能调优技巧知多少? - Redis深度揭秘:你知道多少?从基础到哨兵、主从复制全梳理 - Redis持久化及哨兵模式详解,还有集群搭建和Leader选举黑箱打开 - Zookeeper是个啥?特性和应用场景大公开 - ZooKeeper集群搭建攻略及 Leader选举、读写一致性、共享锁实现细节 - 探究ZooKeeper中的Leader选举机制及其在分布式环境中的作用 - Zab协议深入剖析:原理、功能与在Zookeeper中的核心地位 - RabbitMQ全方位解读:工作模式、消费限流、可靠投递与配置策略 - 设计者视角:RabbitMQ过期时间、死信队列与延时队列实践指南 - RocketMQ特性和应用场景揭示:理解其精髓与差异化优势 - Kafka详细介绍:特性及广泛应用于实时数据处理的场景解析 - ElasticSearch实力揭秘:特性概述与作为搜索引擎的广泛应用 - MongoDB认知升级:非关系型数据库的优势阐述,安装与使用实战教学 - BIO/NIO/AIO网络模型对比:掌握它们的区别与在网络编程中的实际应用 - Netty带你飞:理解其超快速度背后的秘密,包括线程模型分析 - 网络通信黑科技:Netty编解码原理与常用编解码器的应用,Protostuff实战演示 - 解密Netty粘包与拆包现象,怎样有效应对这一常见问题 - 自定义Netty心跳检测机制,轻松调整检测间隔时间的艺术 - Dubbo轻骑兵介绍:核心特性概览,服务降级实战与其实现益处 - Dubbo三大神器解读:本地存根与本地伪装的实战运用与优势呈现 ----------------------- 七、结语与回顾
-
Python中的队列(Queue)功能及其实际操作指南
-
C++ STL中的queue队列容器详解:入门指南、特性解析、push、pop和front函数操作
-
玩转Python:理解多线程中的锁机制、全局锁、Queue队列及线程池应用实例
-
理解RabbitMQ队列(Queue)中的各项参数及其作用
-
深入理解Python中的queue队列(一)
-
简单易懂!详解Python中的queue模块功能
-
彻底理解Python中的Queue(队列)模块
-
C++中的优先级队列(Priority Queue)及其运算符重载