python队列溢出_Python queue队列

今天药忘吃喽~ 2022-11-01 00:59 132阅读 0赞

Queue

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

基本FIFO队列

class Queue.Queue(maxsize=0)

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

举个栗子：

1 importQueue2

3 q =Queue.Queue()4

5 for i in range(5):6 q.put(i)7

8 while notq.empty():9 print q.get()

输出：

01

2

3

4

LIFO队列

class Queue.LifoQueue(maxsize=0)

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

再举个栗子：

1 importQueue2

3 q =Queue.LifoQueue()4

5 for i in range(5):6 q.put(i)7

8 while notq.empty():9 print q.get()

输出：

4

3

2

10

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

优先级队列

class Queue.PriorityQueue(maxsize=0)

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

importQueueimportthreadingclassJob(object):def \_\_init\_\_(self, priority, description):

self.priority=priority

self.description=descriptionprint 'Job:',descriptionreturn

def \_\_cmp\_\_(self, other):returncmp(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'))defprocess\_job(q):whileTrue:

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 inworkers:

w.setDaemon(True)

w.start()

q.join()

结果

Job: level3job

Job: level10job

Job: level1jobfor: level 1jobfor: level 3jobfor: 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

发表评论取消回复

表情：

评论列表（有 0 条评论，132人围观）

还没有评论，来说两句吧...

相关阅读

相关 Python中的队列(Queue)

Python中的队列(Queue) 队列(Queue)是一种常用的数据结构，用于在先进先出的原则下存储和访问元素。在Python中，Queue模块提供了实现队列的类。 Py

拼搏现实的明天。/ 2024年03月17日 13:59/ 0 赞/ 18 阅读

相关 Python - 优先队列（queue.PriorityQueue & heapq）

目录什么是优先队列为什么需要优先队列？优先队列是个啥？优先队列的工作原理 Python实现一个优先队列 Python内置库中的queue.PriorityQ

た入场券/ 2023年09月26日 22:08/ 0 赞/ 144 阅读

相关 python队列溢出_Python queue队列

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

今天药忘吃喽~/ 2022年11月01日 00:59/ 0 赞/ 133 阅读

相关 Python 队列(Queue) Demo

> Python的多线程有个队列模块Queue > 这个模块就相当于创建一个线程池。举一个例子说明。一下这个Queue，比如我每天都去的吃的乔晨粗粮包子店。假如这个包子店的

以你之姓@/ 2022年05月30日 00:21/ 0 赞/ 166 阅读

相关队列Queue

队列是一种数据结构，它只允许在队列尾部（rear）加人一个元素，和从队列头部（front）移除一个元素。进行插入操作的端称为队尾，进行删除操作的端称为队头。队列中没有元素时，称

我就是我/ 2022年02月24日 17:29/ 0 赞/ 297 阅读

相关 Queue--队列

队列（Queue）和栈不同，队列是只允许在一端插入，在另一端进行删除的线性表，所有的插入操作都在队尾进行，删除操作则在队头进行。入队和出队顺序一样。由于数组在删除元素的时候

淩亂°似流年/ 2022年02月03日 16:25/ 0 赞/ 302 阅读

相关 Queue队列

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][] /\\ \ 在java5中新增加了java.util

淩亂°似流年/ 2022年01月16日 01:31/ 0 赞/ 306 阅读

相关 python queue - 同步队列类

参考 [官网][Link 1] queue 模块 queue 模块实现多生产者，多消费者队列。当必须在 ==多个线程之间安全地交换信息== 时，它在线程编程中特别

我就是我/ 2021年10月26日 14:26/ 0 赞/ 260 阅读

相关 Python模块-queue队列模块

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][] 队列方法 q = queue.Queue().pu

左手的ㄟ右手/ 2021年09月20日 05:20/ 0 赞/ 461 阅读

相关 queue 队列

import java.util.ArrayDeque; import java.util.PriorityQueue; / 2017-02-

￡神魔★判官ぃ/ 2021年09月11日 07:16/ 0 赞/ 387 阅读