菜单

Python queue队列

2019年4月7日 - 金沙编程资讯

 

队列:

 

单抽象出生产者和买主,还够不上是生产者/消费者形式。该模还亟需有一个缓冲区处于生产者和顾客之间,作为3个中介。生产者把多少放入缓冲区,而消费者从缓冲区取出数据。

# 存储数据时可设置优先级的队列
# 优先级设置数越小等级越高
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')]

   解耦:使程序直接促成松耦合,修改2个函数,不会有串联关系。

劳动者消费者模型:

本条阻塞队列便是⽤来给⽣产者和顾客解耦的。纵观⼤多数设计格局,都会找⼀个目生人出来进⾏解耦

 

   进步处理功用:FIFO = 现进先出,LIFO = 后入先出。

   升高处理功能:FIFO = 现进先出,LIFO = 后入先出。

⽣产者消费者方式是通过⼀个容器来解决⽣产者和买主的强耦合难点。⽣产者和消费者相互之间不直接通信,⽽通过阻塞队列来进⾏通信,所以⽣产者⽣产完数据今后不⽤等待顾客处理,直接扔给卡住队列,消费者不找⽣产者要多少,⽽是直接从绿灯队列⾥取,阻塞队列就也正是⼀个缓冲区,平衡了⽣产者和买主的处理能⼒。

 

# 先入先出 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()

队列:

Python的Queue模块中提供了协同的、线程安全的系列类,包罗FIFO(先⼊先出)队列Queue,LIFO(后⼊先出)队列LifoQueue,和先期级队列PriorityQueue。那一个队列都实现了锁原语(能够明白为原⼦操作,即要么不做,要么就做完),能够在多线程中央直属机关接使⽤。能够使⽤队列来完成线程间的三只。

   解耦:使程序直接促成松耦合,修改三个函数,不会有串联关系。

 

参数介绍:

在线程世界⾥,⽣产者便是⽣产数据的线程,消费者正是消费数据的线程。在二十八线程开发在那之中,尽管⽣产者处理速度相当慢,⽽消费者处理速度一点也不快,那么⽣产者就亟须等待买主处理完,才能继续⽣产数据。同样的道理,如若消费者的处理能⼒⼤于⽣产者,那么消费者就非得等待⽣产者。为了化解这些题材于是引⼊了⽣产者和买主方式。

 

 

 

⽣产者消费者情势的表明:

 

参数介绍:

作用:

澳门金沙国际,在骨子里的软件开发进程中,平日会遇见如下场景:某些模块负责发生多少,这么些数量由另1个模块来顶住处理(此处的模块是广义的,能够是类、函数、线程、进度等)。产⽣数据的模块,就形象地称之为生产者;⽽而处理数量的模块,就叫做消费者。

LifoOueue
后进先出队列:

作用:

# 先入先出 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()

相关文章

发表评论

电子邮件地址不会被公开。 必填项已用*标注

网站地图xml地图