本文主要介绍python队列,通过示例代码非常详细的介绍,对大家的学习或者工作有一定的参考价值。有需要的朋友下面和边肖一起学习。
Queue
它是QueuePython标准库中的线程安全队列(FIFO)实现。它提供了一种适合多线程编程的先进先出数据结构,即队列,用于生产者线程和消费者线程之间传递信息。
基本FIFO队列
班级队列。队列(maxsize=0)
即先进先出,先入先出。队列提供了一个简单易用的FIFO容器。maxsize是一个整数,表示队列中可以存储的数据数量的上限。一旦达到上限,插入将导致阻塞,直到队列中的数据用完。如果maxsize小于或等于0,则队列大小没有限制。
举个栗子:
导入队列
q=队列。队列()
对于范围(5)中的I:
q.put(i)
而不是q.empty():
print q.get()
输出:
0
一个
2
三
四
LIFO队列
班级队列。LifoQueue(maxsize=0)
LIFO的意思是后进先出,后进先出。类似于stack,用起来也很简单,maxsize同上。
再给我举个栗子:
导入队列
q=队列。LifoQueue()
对于范围(5)中的I:
q.put(i)
而不是q.empty():
print q.get()
输出:
四
三
2
一个
0
您可以看到,您只是替换了队列。队列中的Quenu类。LifiQueue类。
优先队列
班级队列。PriorityQueue(maxsize=0)
构建一个优先级队列。Maxsize的用法同上。
导入队列
导入线程
类别作业(对象):
def __init__(自身,优先级,描述):
自我优先=优先权
自我描述=描述
打印“作业:”描述
返回
def __cmp__(自身,其他):
返回cmp(自身优先级,其他优先级)
q=队列。优先级队列()
q.put(Job(3,' 3级作业'))
q.put(Job(10,' 10级作业'))
q.put(Job(1,' 1级作业'))
定义进程_作业(q):
虽然正确:
next_job=q.get()
打印“用于:”,下一个作业。描述
q.task_done()
工人=[穿线。Thread(target=process_job,args=(q,),
穿线。线程(target=process_job,args=(q,))
]
对于工人中的w:
w.setDaemon(True)
w .启动()
问加入()
结果
职务:3级职务
工作:10级工作
职务:一级职务
适用于:1级工作
适用于:3级工作
适用于:职务:10级职务
一些常用方法
task_done()
意味着之前加入团队的一个任务已经完成。由队列的使用者线程调用。每个get()调用获得一个任务,下一个task_done()调用告诉队列任务已经被处理。
如果当前的join()正在阻塞,那么当队列中的所有任务都被处理后,它将恢复执行(也就是说,put()所排队的每个任务都有一个相应的task_done()调用)。
join()
阻塞调用线程,直到队列中的所有任务都被处理完。
只要数据被添加到队列中,未完成任务的数量就会增加。当消费者线程调用task_done()时,意味着一个消费者获得了任务并完成了它,未完成的任务数量就会减少。当未完成任务的数量下降到0时,join()解除阻塞。
put(项目[,块[,超时]])
将项目放入队列。
如果可选参数block为True,timeout为空对象(默认情况是阻塞调用,无超时)。
如果timeout是正整数,调用进程将被阻塞长达超时秒。如果始终没有可用的空闲空间,将抛出一个完全异常(超时阻塞调用)。
如果block为False,如果有可用的空闲空间,则将数据放入队列中;否则,立即抛出完整异常。
它的非阻塞版本是put_nowait,相当于put(item,False)
get([block[, timeout]])
从队列中移除并返回一条数据。与带有blocktimeout参数的put方法相同。
它的非阻塞方法是“get _ nowait()”,相当于get(False)
empty()
如果队列为空,则返回True,否则返回False。
以上是边肖介绍的python队列的详细讲解和集成。希望对你有帮助。如果您有任何问题,请给我留言,边肖将及时回复您。非常感谢您对我们网站的支持!
郑重声明:本文由网友发布,不代表盛行IT的观点,版权归原作者所有,仅为传播更多信息之目的,如有侵权请联系,我们将第一时间修改或删除,多谢。