python队列只能一个个读取吗_python队列Queue的详解

Queue

Queue是python标准库中的线程安全的队列(FIFO)实现,提供了一个适用于多线程编程的先进先出的数据结构,即队列,用来在生产者和消费者线程之间的信息传递

基本FIFO队列

class Queue.Queue(maxsize=0)

FIFO即First in First Out,先进先出。Queue提供了一个基本的FIFO容器,使用方法很简单,maxsize是个整数,指明了队列中能存放的数据个数的上限。一旦达到上限,插入会导致阻塞,直到队列中的数据被消费掉。如果maxsize小于或者等于0,队列大小没有限制。

举个栗子:

import Queue

q = Queue.Queue()

for i in range(5):

q.put(i)

while not q.empty():

print q.get()

输出:

0

1

2

3

4

LIFO队列

class Queue.LifoQueue(maxsize=0)

LIFO即Last in First Out,后进先出。与栈的类似,使用也很简单,maxsize用法同上

再举个栗子:

import Queue

q = Queue.LifoQueue()

for i in range(5):

q.put(i)

while not q.empty():

print q.get()

输出:

4

3

2

1

0

可以看到仅仅是将Queue.Quenu类替换为Queue.LifiQueue类

优先级队列

class Queue.PriorityQueue(maxsize=0)

构造一个优先队列。maxsize用法同上。

import Queue

import threading

class Job(object):

def __init__(self, priority, description):

self.priority = priority

self.description = description

print 'Job:',description

return

def __cmp__(self, other):

return cmp(self.priority, other.priority)

q = Queue.PriorityQueue()

q.put(Job(3, 'level 3 job'))

q.put(Job(10, 'level 10 job'))

q.put(Job(1, 'level 1 job'))

def process_job(q):

while True:

next_job = q.get()

print 'for:', next_job.description

q.task_done()

workers = [threading.Thread(target=process_job, args=(q,)),

threading.Thread(target=process_job, args=(q,))

]

for w in workers:

w.setDaemon(True)

w.start()

q.join()

结果

Job: level 3 job

Job: level 10 job

Job: level 1 job

for: level 1 job

for: level 3 job

for: job: level 10 job

一些常用方法

task_done()

意味着之前入队的一个任务已经完成。由队列的消费者线程调用。每一个get()调用得到一个任务,接下来的task_done()调用告诉队列该任务已经处理完毕。

如果当前一个join()正在阻塞,它将在队列中的所有任务都处理完时恢复执行(即每一个由put()调用入队的任务都有一个对应的task_done()调用)。

join()

阻塞调用线程,直到队列中的所有任务被处理掉。

只要有数据被加入队列,未完成的任务数就会增加。当消费者线程调用task_done()(意味着有消费者取得任务并完成任务),未完成的任务数就会减少。当未完成的任务数降到0,join()解除阻塞。

put(item[, block[, timeout]])

将item放入队列中。

如果可选的参数block为True且timeout为空对象(默认的情况,阻塞调用,无超时)。

如果timeout是个正整数,阻塞调用进程最多timeout秒,如果一直无空空间可用,抛出Full异常(带超时的阻塞调用)。

如果block为False,如果有空闲空间可用将数据放入队列,否则立即抛出Full异常

其非阻塞版本为put_nowait等同于put(item, False)

get([block[, timeout]])

从队列中移除并返回一个数据。block跟timeout参数同put方法

其非阻塞方法为`get_nowait()`相当与get(False)

empty()

如果队列为空,返回True,反之返回False

以上所述是小编给大家介绍的python队列Queue详解整合,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对脚本之家网站的支持!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/468049.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

C#基于LibUsbDotNet实现USB通信(一)

网上C#USB通信的资料比较少, 基本上都是基于LibUsbDotNet 和 CyUsb, 关于打印机设备的还有一个OPOS。 本篇文章基于LibUsbDotNet。 1. 下载并安装 LibUsbDotNet 安装文件。 2. 运行Filter Wizard, Install a device filter。 安装需要通信的usb设备。 3. 建一个简单…

一个大神的Android成长之路

这篇文章是我的一个朋友写的,总结了这些年的技术成长之路,我觉得对于很多技术人都有借鉴的作用,技术是相通的,不要整天想一口气吃成一个胖子,不积跬步无以至千里,既然选择了技术这条路,就不畏艰…

银联Apple Pay 总结

最近在空余的时间做了银联Apple Pay,是银联快捷支付,在手机钱包里面绑定银行卡,在购买商品的时候直接指纹支付就可以了. 首先你看一线Apple Pay的官方文档:Apple Pay Human Interface Guidelines. 因为按钮和界面的原因,苹果拒绝我2次了. 按钮要使用苹果自带的Apple Pay按钮,要…

jsp页面内引入静态html,JSP技术实现动态页面到静态页面的方法

本文是介绍了jsp技术实现动态页面到静态页面的方法,分享给大家,具体如下:对于JSP技术实现动态页面到静态页面的方案,我们从三个步骤来说明:JSP技术实现动态页面到静态页面的方案第一:为了能深入浅出的理解这…

python loads_python dumps和loads区别详解

这篇文章主要介绍了python dumps和loads区别详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下一.概念理解json是一种轻量级的数据交换格式,对象由花括号括起来的逗号分割的成员构成,成…

串口通讯你真的会了吗?不妨看看这些经验

平时使用串口打印出现乱码的绝大部分原因是串口波特率没对。那么我们怎么测量实际的波特率呢?在这之前,顺便一起回顾一下波特率的概念。什么是波特率、比特率? 比特率(Bitrate)表示每秒钟传输的二进制位数,单位为比特每秒(bit/s)。…

html分类代码查询,html标签元素分类(示例代码)

在CSS中,HTML中的标签元素可以被分成三种类型,分别是:块状元素、内联元素和内联块状元素。常用的块状元素有:、、(......标题)、、、、(长引用)、块状元素的特点:1、一个块状元素独占一行;2、块状元素的高度…

7月27

Ddl语句,数据定义表 ,创建删除。SQL 结构化查询语句 DML数据操控表:对数据进行操作,如增删查改 Grid control网络控制 control 像是一个集成的管理工具。Bi做数据仓库的应用。 Entity实体集 每个实体集是表,每个…

一些函数、变量命名法及代码规范

驼峰命名法 骆驼式命名法(Camel-Case)又称驼峰式命名法,也称小驼峰式命名法。骆驼式命名法就是当变量名或函数名是由一个或多个单词连结在一起时,第一个单词以小写字母开始;从第二个单词开始以后的每个单词的首字母都采…

linux 信号_[入门]谈一谈Linux中的信号

也许有一些同学有这样的疑问:kill -9 PID 中的 -9 到底是什么意思?Ctrl C 是为什么可以停止掉运行的程序?1. 什么是信号?在计算机科学中,信号是Unix、类Unix以及其他POSIX兼容的操作系统中进程间通讯的一种有限制的方…

计算机应用技术专业课程改革方案,【计算机维护论文】计算机应用技术专业教学改革方案(共4015字)...

一、新课改背景下计算机应用技术专业教学创新型改革的必要性新课改背景下计算机应用技术专业教学创新新改革的必要性主要包括以下三点。第一,当前计算机应用技术专业教学存在教学计划单一且教学缺乏灵活性和创新性的问题,在一定程度上制约和影响计算机应…

多校第二场C题

水贪心 #include<algorithm> #include<iostream> #include<cstring> #include<cstdlib> #include<cstdio> #include<queue> #include<set> using namespace std; typedef long long ll; typedef pair<int,int> pii; #define M…

终于讲透了,史上最详细的RS485串口通讯!

RS485接口组成的半双工网络&#xff0c;一般是两线制&#xff0c;多采用屏蔽双绞线传输&#xff0c;这种接线方式为总线式拓扑结构在同一总线上最多可以挂接32个结点。我们知道&#xff0c;最初数据是模拟信号输出简单过程量&#xff0c;后来仪表接口是RS232接口&#xff0c;这…

python求解不等式组_解线性方程组和线性不等式组

你的问题是线性规划中的问题&#xff0c;你的等式和不等式是限制&#xff0c;你想最小化(然后最大化)表达式y。等式、不等式和表达式都是线性的&#xff0c;所以它是线性规划。使用scipy函数的scipy包可以进行这种线性规划。在这里是注释代码&#xff0c;可以做你想做的。注意&…

昆明大学津桥学院计算机科学与技术,昆明理工大学津桥学院计算机科学与技术专业2015年在河南理科高考录取最低分数线...

类似问题答案昆明理工大学津桥学院计算机科学与技术专业2015年在河北理科高考录取最低分数线学校 地 区 专业 年份 批次 类型 分数 昆明理工大学津桥学院 河北 计算机科学与技术 2015 三批 理科 363 学校 地 区 专业 年份 批次 类型 分数 昆明理工大学津桥学院 河北 计算机科学…

关于处理百万级大批量数据的mysql运行几个重要点

处理大批量百万级的数据几点重要知识点&#xff1a; 一&#xff1a;设置php运行的内存配置 ini_set("memory_limit","1200M"); 在php.ini中有如下配置 ; Maximum input variable nesting level  ; http://php.net/max-input-nesting-level  ;max_input…

react 组件封装原则_我理解的React:React 到底是什么?

希望本文能帮助没接触过 React 的同学&#xff0c;对React有个大致的理解。最近要做一个“前端零基础的入门课程分享”&#xff0c;很多非前端同学可能只是知道 React 是个前端框架&#xff0c;整体对 React 的理解还是很模糊&#xff0c;借此机会&#xff0c;分享一下我对 Rea…

解引用NULL为什么会导致程序挂死?

来源&#xff1a;公众号【编程珠玑】作者&#xff1a;守望先生ID&#xff1a;shouwangxiansheng解引用NULL指针为什么会出错&#xff0c;导致程序挂死&#xff1f;或者说访问内存地址为0的位置为什么会视为非法&#xff1f;先了解NULL参考《NULL,0,\0有何区别&#xff1f;》。解…

JAVA多线程实现的三种方式 ()

1、继承Thread类实现多线程 继承Thread类的方法尽管被我列为一种多线程实现方式&#xff0c;但Thread本质上也是实现了Runnable接口的一个实例&#xff0c;它代表一个线程的实例&#xff0c;并且&#xff0c;启动线程的唯一方法就是通过Thread类的start()实例方法。start()方法…

关于主机的思维导图_送给孩子最好的思维导图课程

思维导图寒假班来了1关于思维导图思维导图是一种简单而有效的图形思维工具&#xff0c;主要元素包含图形、线条、关键字、颜色&#xff0c;配合下图&#xff0c;我们能理解思维导图利用了左脑和右脑的工作机理&#xff0c;能够充分调动大脑的分析推理和想象创新能力&#xff0c…