import queue

# 先進(jìn)先出隊(duì)列
queue_obj = queue.Queue()

for i in range(3):
? ? queue_obj.put(i)

for i in range(3):
? ? print(queue_obj.get())

"""執(zhí)行結(jié)果
0
1
2
"""

# 先進(jìn)后出隊(duì)列,類似于堆棧
queue_obj = queue.LifoQueue()

for i in range(3):
? ? queue_obj.put(i)

for i in range(3):
? ? print(queue_obj.get())

"""執(zhí)行結(jié)果
2
1
0
"""

# 優(yōu)先級隊(duì)列
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()

maxsize = 10
queue_obj = queue.Queue(maxsize)  # maxsize 代表隊(duì)列的上限, 如果隊(duì)列已滿, 則插入時(shí)需要等待, maxsize為零或負(fù)數(shù)時(shí).隊(duì)列沒有限制

queue_obj.get(block=True, timeout=None)  # block為True時(shí),表示等待獲取,直至timeout超時(shí)
queue_obj.get_nowait()  # 當(dāng)獲取不到元素時(shí),報(bào)錯(cuò)

queue_obj.put(item="待插入的元素", block=True, timeout=None)  # block為True時(shí),表示等待插入,直至timeout超時(shí)
queue_obj.put_nowait('待插入的元素')  # 當(dāng)不能插入元素時(shí)報(bào)錯(cuò)

queue_obj.empty()  # 隊(duì)列為空時(shí),返回True

queue_obj.full()  # 如果隊(duì)列滿時(shí),返回True

queue_obj.task_done()  # 在每次獲取隊(duì)列中的元素, 操作完成之后, 調(diào)用該函數(shù)告訴隊(duì)列我已經(jīng)使用完成, 主要是給join函數(shù)使用
queue_obj.join()  # 等待隊(duì)列內(nèi)的元素全部被獲取后, 再接觸阻塞(直至所有的任務(wù)全部task_done)

"""下面的例子驗(yàn)證toask_done和join的關(guān)系"""
for i in range(3):
    queue_obj.put(i)  # 這里像隊(duì)列中添加三個(gè)元素

queue_obj.get()  # 這里獲取隊(duì)列中的消息
queue_obj.task_done()

queue_obj.get()  # 這里獲取隊(duì)列中的消息
queue_obj.task_done()

queue_obj.get()  # 這里獲取隊(duì)列中的消息
queue_obj.task_done()

queue_obj.join()
print('直至隊(duì)列中的所有元素全部都被取出, join函數(shù)才不會阻塞, 如果只執(zhí)行了兩次task_done函數(shù), 則join會一直阻塞')

from queue import Queue, LifiQueue, PriorityQueue, SimpleQueue

qsize()
empty()
put(item, block = True, timeout = None )
put_nowait(item)
get(block = True,timeout = None)
get_nowait(item)