1 queue 模块
-
分类(共同点if maxsize <=0 队列长度没有限制.)
-
queue.Queue(maxsize =0) First in first OUT(FIFO)
-
queue.LifoQueue(maxsize=0) 后进先出(Last In First Out: LIFO)队列
-
PriorityQueue(maxsize=0) 优先级队列,比较队列中每个数据的大小,值最小的数据拥有出队列的优先权。数据一般以元组的形式插入,典型形式为(priority_number, data)。如果队列中的数据没有可比性,那么数据将被包装在一个类中,忽略数据值,仅仅比较优先级数字。
-
queue.SimpleQueue 先进先出类型的简单队列,没有大小限制。由于它是简单队列,相比于 Queue 队列会缺少一些高级功能
-
queue.Empty 异常
-
queue.Full 异常
2. queue 的方法
-
Queue.qsize() 返回队列中数据元素的个数。
-
Queue.empty() 如果队列为空,返回 True,否则返回 False。
-
Queue.full() 如果队列中元素个数达到上限,返回 True,否则返回 False。
-
Queue.put(item, block=True, timeout=None)
- item,放入队列中的数据元素。
- block,当队列中元素个数达到上限继续往里放数据时:如果 block=False,直接引发 queue.Full 异常;如果 block=True,且 timeout=None,则一直等待直到有数据出队列后可以放入数据;如果 block=True,且 timeout=N,N 为某一正整数时,则等待 N 秒,如果队列中还没有位置放入数据就引发 queue.Full 异常。
- timeout,设置超时时间
-
Queue.put_nowait(item) 相当于 Queue.put(item, block=False),当队列中元素个数达到上限继续往里放数据时直接引发 queue.Full 异常。
-
Queue.get(block=True, timeout=None)
-
- block,当队列中没有数据元素继续取数据时:如果 block=False,直接引发 queue.Empty 异常;如果 block=True,且 timeout=None,则一直等待直到有数据入队列后可以取出数据;如果 block=True,且 timeout=N,N 为某一正整数时,则等待 N 秒,如果队列中还没有数据放入的话就引发 queue.Empty 异常。
- timeout,设置超时时间
-
Queue.get_nowait() 相当于 Queue.get(block=False)block,当队列中没有数据元素继续取数据时直接引发 queue.Empty 异常。
-
Queue.task_done() 表示队列内的数据元素已经被取出,即每个 get 用于获取一个数据元素, 后续调用 task_done 告诉队列,该数据的处理已经完成。如果被调用的次数多于放入队列中的元素个数,将引发 ValueError 异常。
-
Queue.
join
() 一直阻塞直到队列中的所有数据元素都被取出和执行,只要有元素添加到 queue 中就会增加。当未完成任务的计数等于0,join 就不会阻塞。
原文地址:https://www.cnblogs.com/tingxin/p/12229895.html
时间: 2024-10-18 08:21:58