3

python queue模块

 2 years ago
source link: https://www.hi-roy.com/posts/python-queue%E6%A8%A1%E5%9D%97/
Go to the source link to view the article. You can view the picture content, updated content and better typesetting reading experience. If the link is broken, please click the button below to view the snapshot at that time.
neoserver,ios ssh client

python queue模块

2013-11-13

创建一个“队列”对象

import Queue
myqueue = Queue.Queue(maxsize = 10)

Queue.Queue类即是一个队列的同步实现。队列长度可为无限或者有限。可通过Queue的构造函数的可选参数maxsize来设定队列长度。如果maxsize小于1就表示队列长度无限。

将一个值放入队列中

myqueue.put(10)

调用队列对象的put()方法在队尾插入一个项目。put()有两个参数,第一个item为必需的,为插入项目的值;第二个block为可选参数,默认为1。如果队列当前为空且block为1,put()方法就使调用线程暂停,直到空出一个数据单元。如果block为0,put方法将引发Full异常。

将一个值从队列中取出

myqueue.get()

调用队列对象的get()方法从队头删除并返回一个项目。可选参数为block,默认为True。如果队列为空且block为True,get()就使调用线程暂停,直至有项目可用。如果队列为空且block为False,队列将引发Empty异常。

python queue模块有三种队列:

  1. python queue模块的FIFO队列先进先出。
  2. LIFO类似于堆。即先进后出。
  3. 还有一种是优先级队列级别越低越先出来。

针对这三种队列分别有三个构造函数:

  1. class Queue.Queue(maxsize) FIFO
  2. class Queue.LifoQueue(maxsize) LIFO
  3. class Queue.PriorityQueue(maxsize) 优先级队列

介绍一下此包中的常用方法:

  1. Queue.qsize() 返回队列的大小
  2. Queue.empty() 如果队列为空,返回True,反之False
  3. Queue.full() 如果队列满了,返回True,反之False
  4. Queue.full 与 maxsize 大小对应
  5. Queue.get([block[, timeout]])获取队列,timeout等待时间
  6. Queue.get_nowait() 相当Queue.get(False)
  7. 非阻塞 Queue.put(item) 写入队列,timeout等待时间
  8. Queue.put_nowait(item) 相当Queue.put(item, False)
  9. Queue.task_done() 在完成一项工作之后,Queue.task_done()函数向任务已经完成的队列发送一个信号
  10. Queue.join() 等到队列为空,再执行别的操作 ,和9经常一起使用 在主线程中使用了 queue.join(),导致主线程阻塞。queue.task_done() 表示完成一个 task,并递减没有完成的队列数,当队列全部完成时候,没有task可执行,因此需要发送一个信号,通知被阻塞的主线程,继续运行。

About Joyk


Aggregate valuable and interesting links.
Joyk means Joy of geeK