python queue 模块

Posted 2020-11-25 A running snail,little step ev

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 就不会阻塞。