python队列Queue的详解_Python

queue

queue是python标准库中的线程安全的队列（fifo）实现,提供了一个适用于多线程编程的先进先出的数据结构，即队列，用来在生产者和消费者线程之间的信息传递

基本fifo队列

class queue.queue(maxsize=0)

fifo即first in first out,先进先出。queue提供了一个基本的fifo容器，使用方法很简单,maxsize是个整数，指明了队列中能存放的数据个数的上限。一旦达到上限，插入会导致阻塞，直到队列中的数据被消费掉。如果maxsize小于或者等于0，队列大小没有限制。

举个栗子：

				?

									import queue

									q = queue.queue()

									for i in range(5):

									  q.put(i)

									while not q.empty():

									  print q.get()

输出：

0
1
2
3
4

lifo队列

class queue.lifoqueue(maxsize=0)

lifo即last in first out,后进先出。与栈的类似，使用也很简单,maxsize用法同上

再举个栗子：

				?

									import queue

									q = queue.lifoqueue()

									for i in range(5):

									  q.put(i)

									while not q.empty():

									  print q.get()

输出：

4
3
2
1
0

可以看到仅仅是将queue.quenu类替换为queue.lifiqueue类

优先级队列

class queue.priorityqueue(maxsize=0)

构造一个优先队列。maxsize用法同上。

				?

									import queue

									import threading

									class job(object):

									  def __init__(self, priority, description):

									    self.priority = priority

									    self.description = description

									    print 'job:',description

									    return

									  def __cmp__(self, other):

									    return cmp(self.priority, other.priority)

									q = queue.priorityqueue()

									q.put(job(3, 'level 3 job'))

									q.put(job(10, 'level 10 job'))

									q.put(job(1, 'level 1 job'))

									def process_job(q):

									  while true:

									    next_job = q.get()

									    print 'for:', next_job.description

									    q.task_done()

									workers = [threading.thread(target=process_job, args=(q,)),

									    threading.thread(target=process_job, args=(q,))

									    ]

									for w in workers:

									  w.setdaemon(true)

									  w.start()

									q.join()