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

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

　　Python 2 中的Queue模塊在Python 3中更名為 queue。

?

Queue對象的創建

　　可以通過實例化Queue類型獲得隊列對象：

1	q?=?Queue.Queue(maxsize=0)

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

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

?

Queue模塊定義的異常類

1	Queue.Empty

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

?

1	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)即不論隊列空否，都不阻塞等待。

例如：

1 2 3 4

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

總結

以上是生活随笔為你收集整理的Python多线程（3）——Queue模块的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。