python Queue模块

快来打我* 2021-11-10 04:00 271阅读 0赞

### [python Queue模块][python Queue] ###

转自：[http://blog.csdn.net/bravezhe/article/details/8588437][python Queue]

分类： [PYTHON][] 2013-02-18 16:43  3864人阅读  [评论][Link 1](1)  收藏  [举报][Link 2]

**创建一个“队列”对象**  
  
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) 优先级队列   
  
介绍一下此包中的常用方法:  
  
Queue.qsize() 返回队列的大小   
Queue.empty() 如果队列为空，返回True,反之False   
Queue.full() 如果队列满了，返回True,反之False  
Queue.full 与 maxsize 大小对应   
Queue.get(\[block\[, timeout\]\])获取队列，timeout等待时间   
Queue.get\_nowait() 相当Queue.get(False)  
非阻塞 Queue.put(item) 写入队列，timeout等待时间   
Queue.put\_nowait(item) 相当Queue.put(item, False)  
Queue.task\_done() 在完成一项工作之后，Queue.task\_done()函数向任务已经完成的队列发送一个信号  
Queue.join() 实际上意味着等到队列为空，再执行别的操作

**附上一个例子:**

**\#coding:utf-8  
  
import Queue  
import threading  
import time  
import random  
  
q = Queue.Queue(0) \#当有多个线程共享一个东西的时候就可以用它了  
NUM\_WORKERS = 3  
  
class MyThread(threading.Thread):  
  
    def \_\_init\_\_(self,input,worktype):  
       self.\_jobq = input  
       self.\_work\_type = worktype  
       threading.Thread.\_\_init\_\_(self)  
  
    def run(self):  
       while True:  
           if self.\_jobq.qsize() > 0:  
               self.\_process\_job(self.\_jobq.get(),self.\_work\_type)  
           else:break  
  
    def \_process\_job(self, job, worktype):  
       doJob(job,worktype)  
  
def doJob(job, worktype):  
   time.sleep(random.random() \* 3)  
    print"doing",job," worktype ",worktype  
  
if \_\_name\_\_ == '\_\_main\_\_':  
    print "begin...."  
    for i inrange(NUM\_WORKERS \* 2):  
       q.put(i) \#放入到任务队列中去  
    print "job qsize:",q.qsize()  
  
    for x inrange(NUM\_WORKERS):  
       MyThread(q,x).start()**

转载于:https://www.cnblogs.com/DjangoBlog/p/3501499.html

[python Queue]: http://blog.csdn.net/bravezhe/article/details/8588437
[PYTHON]: http://blog.csdn.net/bravezhe/article/category/1074412
[Link 1]: http://blog.csdn.net/bravezhe/article/details/8588437#comments
[Link 2]: http://blog.csdn.net/bravezhe/article/details/8588437#report