python队列
2020-01-15 05:42
71 查看
对于队列的使用还不是很明确,暂时先保存一个看到的写的很好的博客的内容--------
Python queue队列
作用:
解耦:使程序直接实现松耦合,修改一个函数,不会有串联关系。
提高处理效率:FIFO = 现进先出,LIFO = 后入先出。
队列:
队列可以并发的派多个线程,对排列的线程处理,并切每个需要处理线程只需要将请求的数据放入队列容器的内存中,线程不需要等待,当排列完毕处理完数据后,线程在准时来取数据即可。请求数据的线程只与这个队列容器存在关系,处理数据的线程down掉不会影响到请求数据的线程,队列会派给其他线程处理这分数据,它实现了解耦,提高效率。队列内会有一个有顺序的容器,列表与这个容器是有区别的,列表中数据虽然是排列的,但数据被取走后还会保留,而队列中这个容器的数据被取后将不会保留。当必须在多个线程之间安全地交换信息时,队列在线程编程中特别有用。
Python四种类型的队例:
Queue:FIFO 即first in first out 先进先出
LifoQueue:LIFO 即last in first out 后进先出(栈)
PriorityQueue:优先队列,级别越低,越优先 deque:双边队列
导入三种队列,包
from queue import Queue,LifoQueue,PriorityQueue
Queue 先进先出队列:
#基本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']) c d
生产消费模型:
#生产消费模型 qq = Queue(maxsize=10) def product(name): count = 1 while True: q.put('步枪{}'.format(count)) print('{}生产步枪{}支'.format(name,count)) count+=1 time.sleep(0.3) def cousume(name): while True: print('{}装备了{}'.format(name,q.get())) time.sleep(0.3) q.task_done() #部队线程 p = threading.Thread(target=product,args=('张三',)) k = threading.Thread(target=cousume,args=('李四',)) w = threading.Thread(target=cousume,args=('王五',)) p.start() k.start() w.start()
- 点赞
- 收藏
- 分享
- 文章举报
相关文章推荐
- python多线程以及同步队列(转)
- python3中分别用递归,栈,和队列打印出目录中所有文件的绝对路径的三种方法
- python队列实例
- Python Celery多队列配置代码实例
- Python数据结构之实现队列
- 人工智能(PythonNet)—— 进程间通信(管道、消息队列、共享内存、信号、信号量、套接字)
- python 多线程 +队列下载资源
- 《剑指Offer》——栈和队列(Python3 实现)
- 数据结构Python实现-队列
- Python3-线程应用队列(生产者与消费者模式--多生产者VS多消费者)
- Python开发【模块】:Celery 分布式异步消息任务队列
- python三种遍历目录的方法递归 栈 和队列
- Python 10--协程、异步IO、redis缓存、rabbitMQ队列
- python网络编程-线程队列queue
- python转行系列7:pymqi获取IBM MQ队列属性
- Python用List实现栈和队列
- 容易理解的python用队列实现广度优先遍历文件
- Python队列及在微信机器人中的应用
- python线程优先级队列( Queue)
- 数据结构与算法(二):栈和队列的python实现