摘要：這篇文章主要介紹了python 隊列詳解的相關(guān)資料,并附簡單實例代碼.隊列特性：先進先出（FIFO)——先進隊列的元素先出隊列。來源于我們生活中的隊列（先排隊的先辦完事）。Queue模塊最常與threading模塊一起構(gòu)成生產(chǎn)-消費者模型，提供了一個適用于多線程編程的先進先出的數(shù)據(jù)結(jié)構(gòu)，即隊列。該模塊源碼中包含5個類：其中，Empty和Full是兩個異常類，當隊列的Queue.get(block=
這篇文章主要介紹了python 隊列詳解的相關(guān)資料,并附簡單實例代碼.
隊列特性：先進先出（FIFO)——先進隊列的元素先出隊列。來源于我們生活中的隊列（先排隊的先辦完事）。
Queue模塊最常與threading模塊一起構(gòu)成生產(chǎn)-消費者模型，提供了一個適用于多線程編程的先進先出的數(shù)據(jù)結(jié)構(gòu)，即隊列。
該模塊源碼中包含5個類：
其中，Empty和Full是兩個異常類，當隊列的Queue.get(block=0)或者調(diào)用get_nowait()時，如果隊列為空，則拋EmptyException異常。
同理，當隊列的Queue.put(block=0)或者調(diào)用put_nowait()時，如果隊列為達到maxsize，則拋FullException異常。
其他三個類：
Queue類：典型的隊列模型，F(xiàn)IFO先入先出?！ lass Queue.Queue(maxsize) maxsize為隊列長度，指明了隊列中能存放的數(shù)據(jù)個數(shù)的上限。一旦達到上限，插入會導(dǎo)致阻 塞，
直到隊列中的數(shù)據(jù)被消費掉。如果maxsize小于或者等于0，隊列大小沒有限制。
LifoQueue類：繼承自Queue，類似于堆棧，先入后出?！ lass Queue.LifoQueue(maxsize)
PriorityQueue類：繼承自Queue，優(yōu)先級隊列，級別越低越先出來?！ lass Queue.PriorityQueue(maxsize)
所以，只要搞定Queue類，就基本搞定Queue模塊。
Queue類中常用的方法：
Queue.qsize() 返回隊列的大小
Queue.empty() 如果隊列為空，返回True,反之False
Queue.full() 如果隊列滿了，返回True,反之False
Queue.full 與 maxsize 大小對應(yīng)
Queue.get([block[, timeout]]) 獲取隊列，timeout等待時間 ，調(diào)用隊列對象的get()方法從隊頭刪除并返回一個項目?？蛇x參數(shù)為block，默認為True。如果隊列為空且block為True，get()就使調(diào)用線程暫停，直至有項目可用。如果隊列為空且block為False，隊列將引發(fā)Empty異常。
Queue.get_nowait() 相當于Queue.get(False)
Queue.put(item）
寫入隊列，timeout等待時間 ,調(diào)用隊列對象的put()方法在隊尾插入一個項目。put()有兩個參數(shù)，第一個item為必需的，為插入項目的值；第 二個block為可選參數(shù)，默認為1。如果隊列當前為空且block為1，put()方法就使調(diào)用線程暫停,直到空出一個數(shù)據(jù)單元。如果block為0，put方法將引發(fā)Full異常。
Queue.put_nowait(item) 相當Queue.put(item, False)
Queue.task_done(）
在完成一項工作之后，Queue.task_done()函數(shù)向任務(wù)已經(jīng)完成的隊列發(fā)送一個信號
Queue.join()
實際上意味著等到隊列為空，再執(zhí)行別的操作
一個小的練習(xí)實例：
#coding:utf-8
import random, threading, time
import Queue
'''
實現(xiàn)了一個生產(chǎn)線程，用于往隊列中添加隨機數(shù)10個，
實現(xiàn)了一個消費線程，分別消耗奇數(shù)隨機數(shù)和偶數(shù)隨機數(shù)
'''
class producer(threading.Thread):
def __init__(self,t_name,queue):
threading.Thread.__init__(self,name=t_name)
self.data = queue
def run(self):
for i in xrange(10):
random_num = random.randint(1,99)
print "%s : %s 生產(chǎn)了一個隨機數(shù)\033[31;0m %d \033[0m放入隊列中" % (time.ctime(),self.getName(),random_num)
self.data.put(random_num)
time.sleep(1)
print "生產(chǎn)線程完成！！"
class consumer(threading.Thread):
def __init__(self,t_name,queue):
threading.Thread.__init__(self,name=t_name)
self.data = queue
def run(self):
while True:
try:
tmp_num = self.data.get(1,5) #定義超時時間5秒
if tmp_num%2 == 0:
print "%s : %s 消耗了一個隊列中的偶數(shù)隨機數(shù)\033[31;0m %d \033[0m" % (time.ctime(),self.getName(),tmp_num)
time.sleep(2)
else:
print "%s : %s 消耗了一個隊列中的奇數(shù)隨機數(shù)\033[31;0m %d \033[0m" % (time.ctime(), self.getName(), tmp_num)
time.sleep(2)
except:
print "消費線程完成??！" #一旦到達超時時間5秒，會拋異常，break退出循環(huán)
break
def main():
queue = Queue.Queue(0)
pro = producer('Pro', queue)
con = consumer('Con', queue)
pro.start()
con.start()
pro.join()
con.join()
print 'All threads complete!!!'
if __name__ == '__main__':
main()更多關(guān)于python 隊列詳解及實例代碼請關(guān)注PHP中文網(wǎng)（ipnx.cn）其他文章！