python queue队列

作用：

　　　解耦：使程序直接实现松耦合，修改一个函数，不会有串联关系。

　　　提高处理效率：ＦＩＦＯ　＝　现进先出，ＬＩＦＯ　＝　后入先出。

队列：

　　队列可以并发的派多个线程，对排列的线程处理，并切每个需要处理线程只需要将请求的数据放入队列容器的内存中，线程不需要等待，当排列完毕处理完数据后，线程在准时来取数据即可。请求数据的线程只与这个队列容器存在关系，处理数据的线程down掉不会影响到请求数据的线程，队列会派给其他线程处理这分数据，它实现了解耦，提高效率。队列内会有一个有顺序的容器，列表与这个容器是有区别的，列表中数据虽然是排列的，但数据被取走后还会保留，而队列中这个容器的数据被取后将不会保留。当必须在多个线程之间安全地交换信息时，队列在线程编程中特别有用。

1、队列有顺序的容器
2、队列数据只有一份，取出来就没了
3、队列数据放在内存里

Python三种类型的队例：

Queue：FIFO 即first in first out 先进先出
LifoQueue：LIFO 即last in first out 后进先出
PriorityQueue：优先队列，级别越低，越优先

参数介绍：

# 先入先出 maxsize 可设置大小，设置block=False抛异常
class queue.Queue(maxsize=0)  # 后进先出
class queue.LifoQueue(maxsize=0)# 存储数据时可设置优先级的队列
# 优先级设置数越小等级越高
class queue.PriorityQueue(maxsize=0) # 放入数据
Queue.put(item, block=True, timeout=None)# 取出数据 #没有数据将会等待
Queue.get(block=True, timeout=None)# 如果1秒后没取到数据就退出
Queue.get(timeout = 1)# 取数据，如果没数据抛queue.Empty异常
Queue.get_nowait()# 查看队列大小
Queue.qsize()# 返回True,如果空
Queue.empty() #return True if empty  # 设置队列大小
Queue.full() # 后续调用告诉队列，任务的处理是完整的。
Queue.task_done()#print(q.get())#取不到会一直等着，卡着了
#print(q.get(timeout=5))#取不到卡5s,抛出异常
#print(q.get(block=True))#取不到会一直等着，卡着了
#print(q.get(block=False))#取不到会抛异常
#print(q.get_nowait())#取不到抛异常

队列的几种类型实例：import  queue,time,threading
q=queue.Queue()#先入先出，默认未限制大小
q=queue.Queue(maxsize=3)#可存入3个数
q.put('王荔1')#存数据，如果存满了一直卡着
q.put('王荔2')
q.put('王荔3')
print("当前队列剩余%s个"%(q.qsize()))#查当前队列大小
print(q.get())
print(q.get())
print(q.get())
print("当前队列剩余%s个"%(q.qsize()))#先入后出
q=queue.LifoQueue()#先入后出
q.put(1)
q.put(2)
q.put(3)
print("当前队列剩余%s个"%(q.qsize()))
print(q.get())
print(q.get())
print(q.get())
print("当前队列剩余%s个"%(q.qsize()))#可设置优先取出
q=queue.PriorityQueue()
q.put((-1,"王荔"))
q.put((2,"橙子"))
q.put((3,"橙汁"))
print("当前队列剩余%s个"%(q.qsize()))
print(q.get())
print(q.get())
print(q.get())
print("当前队列剩余%s个"%(q.qsize()))C:\Users\wangli\PycharmProjects\AutoMation\venv\Scripts\python.exe C:/Users/wangli/PycharmProjects/AutoMation/case/test.py
当前队列剩余3个
王荔1
王荔2
王荔3
当前队列剩余0个
当前队列剩余3个
3
2
1
当前队列剩余0个
当前队列剩余3个
(-1, '王荔')
(2, '橙子')
(3, '橙汁')
当前队列剩余0个Process finished with exit code 0

#生产者与消费者模型实例：import threading,time
import queue
q = queue.Queue(maxsize=10)
def Producer(name):count = 1while True:q.put("骨头%s" % count)print("生产了骨头",count)count +=1time.sleep(0.1)
def  Consumer(name):while True:print("[%s] 取到[%s] 并且吃了它..." %(name, q.get()))time.sleep(1)
p = threading.Thread(target=Producer,args=("Alex",))
c = threading.Thread(target=Consumer,args=("ChengRonghua",))
c1 = threading.Thread(target=Consumer,args=("王森",))
p.start()
c.start()
c1.start()C:\Users\wangli\PycharmProjects\AutoMation\venv\Scripts\python.exe C:/Users/wangli/PycharmProjects/AutoMation/case/test.py
生产了骨头 1
[ChengRonghua] 取到[骨头1] 并且吃了它...
生产了骨头 2
[王森] 取到[骨头2] 并且吃了它...
生产了骨头 3
生产了骨头 4
生产了骨头 5
生产了骨头 6
生产了骨头 7
生产了骨头 8
生产了骨头 9
生产了骨头 10
[ChengRonghua] 取到[骨头3] 并且吃了它...
生产了骨头 11
[王森] 取到[骨头4] 并且吃了它...
生产了骨头 12
生产了骨头 13
生产了骨头 14
[ChengRonghua] 取到[骨头5] 并且吃了它...
生产了骨头 15
[王森] 取到[骨头6] 并且吃了它...
生产了骨头 16
[ChengRonghua] 取到[骨头7] 并且吃了它...
生产了骨头 17
[王森] 取到[骨头8] 并且吃了它...
生产了骨头 18Process finished with exit code -1

python queue队列相关推荐

Python queue (队列)
queue (队列) 主要作用解耦,使程序实现松耦合(一个模块修改不会影响其他模块) 提高效率队列与列表的关系队列中数据只有一份,取出就没有了,区别于列表,列表数据取出只是复制了一份分类 FI ...
Python之路-python(Queue队列、进程、Gevent协程、Select\Poll\Epoll异步IO与事件驱动)
一.进程: 1.语法 2.进程间通讯 3.进程池二.Gevent协程三.Select\Poll\Epoll异步IO与事件驱动一.进程: 1.语法 1 简单的启动线程语法 2 def run(na ...
python线性表和队列_[笔记]python数据结构之线性表：linkedlist链表,stack栈,queue队列...
python数据结构之线性表 python内置了很多高级数据结构,list,dict,tuple,string,set等,在使用的时候十分舒心.但是,如果从一个初学者的角度利用python学习数据结构 ...
python 实现队列功能 queue insert() pop()
def calculate_detection_num(self, calcu_list, detect_num):"""计算一段次数内平均识别个数"" ...
Python 线程队列 Queue – FIFO - Python零基础入门教程
目录一.Python 线程队列分类二.Python 线程先进先出队列 Queue 简介三.Python 线程先进先出队列 Queue 常用函数四.Python 线程先进先出队列 Queue 使 ...
python 队列实现_Python Queue队列实现线程通信
queue 模块下提供了几个阻塞队列,这些队列主要用于实现线程通信.在 queue 模块下主要提供了三个类,分别代表三种队列,它们的主要区别就在于进队列.出队列的不同. 关于这三个队列类的简单介绍如下 ...
python 优先队列_Python Queue队列实现线程通信
queue 模块下提供了几个阻塞队列,这些队列主要用于实现线程通信.在 queue 模块下主要提供了三个类,分别代表三种队列,它们的主要区别就在于进队列.出队列的不同.关于这三个队列类的简单介绍如下: ...
python数据结构和算法时间复杂度分析乱序单词检测线性数据结构栈stack 字符匹配表达式求值 queue队列链表递归动态规划排序和搜索树图
python数据结构和算法参考本文github 计算机科学是解决问题的研究.计算机科学使用抽象作为表示过程和数据的工具.抽象的数据类型允许程序员通过隐藏数据的细节来管理问题领域的复杂性.Pytho ...
python 消息队列 get是从队首还是队尾取东西_Python -- queue队列模块
import Queue myqueue = Queue.Queue(maxsize = 10) Queue.Queue类即是一个队列的同步实现.队列长度可为无限或者有限.可通过Queue的构造函数的 ...

python queue队列

python queue队列相关推荐

最新文章

热门文章