队列

#coding=utf8

import Queue

q = Queue.LifoQueue()
for i in range(5):
    q.put(i)

while not q.empty():
    print q.get()

print 

#coding=utf8

import Queue, threading

q = Queue.PriorityQueue()

class Job(object):
    def __init__(self, priority, description):
        self.priority = priority
        self.description = description
        print 'new job',description
    
    def __cmp__(self, other):
        return cmp(self.priority, other.priority)

q.put( Job(3, 'mid') )
q.put( Job(10, 'low') )
q.put( Job(1, 'import'))

def process_job(q):
    while True:
        n_j = q.get()
        print 'Processing job:%s \n' % n_j.description
        q.task_done()

works = [
    threading.Thread(target=process_job, args=(q,)),
    threading.Thread(target=process_job, args=(q,)),
    threading.Thread(target=process_job, args=(q,)),
]

for w in works:
    w.setDaemon(True)
    w.start()

q.join()