Python多線程（3）——Queue模塊

　　Queue模塊支持先進先出（FIFO）隊列，支持多線程的訪問，包括一個主要的類型（Queue）和兩個異常類（exception classes）。

　　Python 2 中的Queue模塊在Python 3中改名爲 queue。

 

Queue對象的建立

　　能夠經過實例化Queue類型得到隊列對象：

q = Queue.Queue(maxsize=0)

　　建立新的隊列，參數 maxsize 的含義是：

• 若是 maxsize > 0：當 q 中的元素達到 maxsize 個時，隊列就滿了，此時再有一個線程但願向裏面插入時，若是指定了 block 選項，就會阻塞直到一個線程從裏面抽出一個元素。
• 若是 maxsize <= 0：Python會認爲這是一個沒有容量限制的隊列。

 

Queue模塊定義的異常類

Queue.Empty

　　若是隊列 q 是空的，此時又調用了 q.get(False)，就會拋出該異常。

 

Queue.Full

　　若是隊列q是滿的，而又調用了 q.put(x, False)，就會拋出該異常。

 

Queue對象的方法

q.empty()

 　　判斷隊列是否爲空。

 

q.full()

 　　判斷隊列是否已滿。

 

q.get(block=True, timeout=None)
q.get_nowait()

　　參數 block 爲 False 時，參數 timeout 沒有意義，由於線程不會阻塞：

• 若是隊列不爲空，取走並返回該元素；
• 若是隊列爲空，拋出Queue.Empty

　　block 爲 True 時，結合超時 timeout 判斷當隊列空時，是一直阻塞進程，仍是進程阻塞一段時間。

　　get_nowait()等於get(False)，或者get(timeout=0)即不論隊列空否，都不阻塞等待。

例如：

try:
    x = q.get_nowait()
except Queue.Empty:
    print "no more items to process"

　　

q.put(item, block=True, timeout=None)
q.put_nowait(item)

　　向隊列中插入 item，若是隊列滿了，拋出Queue.Full或線程阻塞等待。

 

q.qsize()

　　返回當前隊列中的元素個數。

 

q.join()

 

q.task_done()