python queue模块

python queue模块有三种队列 python queue模块的FIFO队列先进先出。LIFO类似于堆。即先进后出。还有一种是优先级队列级别越低越先出来。针对这三种队列分别有三个构造函数 class Queue.Queue(maxsize) FIFO class Queue.LifoQueue(maxsize) LIFO 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:

            job = self._jobq.get()

            worktype = self._work_type

            self._process_job(job,worktype)

        else:break

def _process_job(self,job,worktype):

    doJob(job)

def doJob(job):

    time.sleep(random.random() * 3)

    print "doing",job

if __name__ == '__main__':

    print "begin ...."

    for i in range(NUM_WORKERS * 2):

        q.put(i) #放入到任务队列中去

    print "job q size:",q.qsize()

    for x in range(NUM_WORKERS):

        MyThread(q,x).start()

看完上面再结合下python 多线程应用的例子会更好的理解！作者:老王@python python教程老王python,提供pythn相关的python教程和python下载，希望大家能够喜欢

文章内容皆为人工编辑，如有错误，敬请指正。谢谢你关注

本文有 1 篇评论

¹ knox 说 :
2011-9-14 15:02:39

def doJob(job):

time.sleep(random.random() * 3)

print "doing",job

我运行了下好像得改成
def doJob(self,job):

time.sleep(random.random() * 3)

print "doing",job

然后
def _process_job(self,job,worktype):

self.doJob(job)
总之情况就是少了个self，这么添加后在shell上跑才是正确的我的PYTHON SHELL是2.7.2

发表你的见解