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()