python queue - 同步队列类
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了python queue - 同步队列类,小编现在分享给大家,供广大互联网技能从业者学习和参考。文章包含2953字,纯文字阅读大概需要5分钟。
内容图文
![python queue - 同步队列类](/upload/InfoBanner/zyjiaocheng/837/5eb3b3770ab2463e84dc5ea053980ce8.jpg)
参考 官网
queue 模块
queue 模块实现多生产者,多消费者队列。
当必须在 ==多个线程之间安全地交换信息== 时,它在线程编程中特别有用。
此模块中的Queue类实现了所有必需的锁定语义。
这取决于Python中线程支持的可用性;看到线程模块。
该模块实现了三种类型的队列,区别仅在于检索条目的顺序。
三种类型队列
FIFO队列
先入先出。在 FIFO队列 中,添加的第一个任务是第一个检索的任务。
LIFO队列
后入先出。在 LIFO队列 中,最近添加的 item 是第一个被get()
检索的(像堆栈一样运行)。
优先级队列
使用 优先级队列,item 将保持排序(使用heapq模块),并首先被get()
检索到的是最低值的 item。
在内部,模块使用锁来临时阻止竞争线程;
但是,它不是为处理线程内的重入而设计的。
queue 模块定义以下类和异常:
class 类
Queue
FIFO队列的构造函数。
queue.Queue(maxsize=0)
# maxsize是一个整数,用于设置可以放入队列的项目数的上限。
# 达到此大小后,插入将阻止,直到消耗队列项。
# 如果maxsize小于或等于零,则队列大小为无限大。
LifoQueue
LIFO队列的构造函数。
queue.LifoQueue(maxsize=0)
# maxsize是一个整数,用于设置可以放入队列的项目数的上限。
# 达到此大小后,插入将阻止,直到消耗队列项。
# 如果maxsize小于或等于零,则队列大小为无限大。
PriorityQueue
优先级队列的构造函数。
queue.PriorityQueue(maxsize=0)
# maxsize是一个整数,用于设置可以放入队列的项目数的上限。
# 达到此大小后,插入将阻止,直到消耗队列项。
# 如果maxsize小于或等于零,则队列大小为无限大。
# 首先检索最低值的条目(最低值条目是由 sorted(list(entries))[0] )返回的条目。
# 条目的典型模式是以下形式的元组:(priority_number,data)。
异常
Empty
在对空的 Queue对象调用非阻塞 get()
( 或 get_nowait()
)时引发异常。
queue.Empty
Full
在已满的 Queue对象调用非阻塞 get()
( 或 get_nowait()
)时引发异常。
queue.Full
方法
queue 对象(Queue,LifoQueue 或 PriorityQueue)提供下面描述的公共方法。
Queue .qsize () | 返回队列的大致大小。 | 注意,size()>0 不保证后续的 get() 不会阻塞,qsize()<maxsize 也不保证put() 不会阻塞。 |
Queue .empty () | 队列是否为空,是返回True否返回False。 | 如果empty()返回True,则不保证对put()的后续调用不会阻塞。 类似地,如果empty()返回False,则不保证对get()的后续调用不会阻塞 |
Queue .full () | 队列是否已满 | |
Queue .put (item, block=True, timeout=None) | 将 item 放入队列 | 如果可选的block为true且timeout为None(默认值),则在必要时阻塞,直到有空闲插槽可用。 如果timeout是一个正数,它会阻止最多超时秒,如果在该时间内没有可用的空闲槽,则会引发Full异常。 若 block 为 false,如果空闲插槽立即可用,则将项目放在队列上,否则引发完全异常(在这种情况下忽略超时)。 |
Queue .put_nowait (item) | 相当于 put(item, False) |
|
Queue .get (block=True, timeout=None) | 从队列中删除并返回一个item | 如果可选的block为true且timeout为None(默认值),则在必要时阻止,直到某个项可用为止。 如果timeout是一个正数,它会阻止最多超时秒,如果在该时间内没有可用的项,则会引发Empty异常。 若 block 为 false,如果一个项立即可用则返回一个项,否则引发Empty异常(在这种情况下忽略超时)。 |
Queue .get_nowait () | 相当于get(False) |
|
Queue .task_done () | 表示以前排队的任务已完成 | 由队列使用者线程使用。对于用于获取任务的每个get(),对task_done()的后续调用会告知队列该任务的处理已完成。 |
Queue .join () | 主线程等待子线程结束才结束 |
内容总结
以上是互联网集市为您收集整理的python queue - 同步队列类全部内容,希望文章能够帮你解决python queue - 同步队列类所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错,欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 gblab@vip.qq.com 举报,一经查实,本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。