Queue對象?

隊列對象 (Queue, LifoQueue, 或者 PriorityQueue) 提供下列描述的公共方法。

Queue.qsize()?

返回隊列的大致大小。注意，qsize() > 0 不保證后續的 get() 不被阻塞，qsize() < maxsize 也不保證 put() 不被阻塞。

Queue.empty()?

如果隊列為空，返回 True ，否則返回 False 。如果 empty() 返回 True ，不保證后續調用的 put() 不被阻塞。類(lèi)似的，如果 empty() 返回 False ，也不保證后續調用的 get() 不被阻塞。

Queue.full()?

如果隊列是滿(mǎn)的返回 True ，否則返回 False 。如果 full() 返回 True 不保證后續調用的 get() 不被阻塞。類(lèi)似的，如果 full() 返回 False 也不保證后續調用的 put() 不被阻塞。

Queue.put(item, block=True, timeout=None)?

將 item 放入隊列。如果可選參數 block 是 true 并且 timeout 是 None (默認)，則在必要時(shí)阻塞至有空閑插槽可用。如果 timeout 是個(gè)正數，將最多阻塞 timeout 秒，如果在這段時(shí)間沒(méi)有可用的空閑插槽，將引發(fā) Full 異常。反之 (block 是 false)，如果空閑插槽立即可用，則把 item 放入隊列，否則引發(fā) Full 異常 ( 在這種情況下，timeout 將被忽略)。

Queue.put_nowait(item)?

Equivalent to put(item, block=False).

Queue.get(block=True, timeout=None)?

從隊列中移除并返回一個(gè)項目。如果可選參數 block 是 true 并且 timeout 是 None (默認值)，則在必要時(shí)阻塞至項目可得到。如果 timeout 是個(gè)正數，將最多阻塞 timeout 秒，如果在這段時(shí)間內項目不能得到，將引發(fā) Empty 異常。反之 (block 是 false) , 如果一個(gè)項目立即可得到，則返回一個(gè)項目，否則引發(fā) Empty 異常 (這種情況下，timeout 將被忽略)。

POSIX系統3.0之前，以及所有版本的Windows系統中，如果 block 是 true 并且 timeout 是 None ， 這個(gè)操作將進(jìn)入基礎鎖的不間斷等待。這意味著(zhù)，沒(méi)有異常能發(fā)生，尤其是 SIGINT 將不會(huì )觸發(fā) KeyboardInterrupt 異常。

Queue.get_nowait()?

相當于 get(False) 。

提供了兩個(gè)方法，用于支持跟蹤 排隊的任務(wù) 是否 被守護的消費者線(xiàn)程 完整的處理。

Queue.task_done()?

表示前面排隊的任務(wù)已經(jīng)被完成。被隊列的消費者線(xiàn)程使用。每個(gè) get() 被用于獲取一個(gè)任務(wù)， 后續調用 task_done() 告訴隊列，該任務(wù)的處理已經(jīng)完成。

如果 join() 當前正在阻塞，在所有條目都被處理后，將解除阻塞(意味著(zhù)每個(gè) put() 進(jìn)隊列的條目的 task_done() 都被收到)。

如果被調用的次數多于放入隊列中的項目數量，將引發(fā) ValueError 異常 。

Queue.join()?

阻塞至隊列中所有的元素都被接收和處理完畢。

當條目添加到隊列的時(shí)候，未完成任務(wù)的計數就會(huì )增加。每當消費者線(xiàn)程調用 task_done() 表示這個(gè)條目已經(jīng)被回收，該條目所有工作已經(jīng)完成，未完成計數就會(huì )減少。當未完成計數降到零的時(shí)候， join() 阻塞被解除。

如何等待排隊的任務(wù)被完成的示例：

import threading, queue

q = queue.Queue()

def worker():
    while True:
        item = q.get()
        print(f'Working on {item}')
        print(f'Finished {item}')
        q.task_done()

# Turn-on the worker thread.
threading.Thread(target=worker, daemon=True).start()

# Send thirty task requests to the worker.
for item in range(30):
    q.put(item)

# Block until all tasks are done.
q.join()
print('All work completed')

SimpleQueue 對象?

SimpleQueue 對象提供下列描述的公共方法。

SimpleQueue.qsize()?

返回隊列的大致大小。注意，qsize() > 0 不保證后續的 get() 不被阻塞。

SimpleQueue.empty()?

如果隊列為空，返回 True ，否則返回 False 。如果 empty() 返回 False ，不保證后續調用的 get() 不被阻塞。

SimpleQueue.put(item, block=True, timeout=None)?

將 item 放入隊列。此方法永不阻塞，始終成功（除了潛在的低級錯誤，例如內存分配失?。??？蛇x參數 block 和 timeout 僅僅是為了保持 Queue.put() 的兼容性而提供，其值被忽略。

CPython implementation detail: This method has a C implementation which is reentrant. That is, a put() or get() call can be interrupted by another put() call in the same thread without deadlocking or corrupting internal state inside the queue. This makes it appropriate for use in destructors such as __del__ methods or weakref callbacks.

SimpleQueue.put_nowait(item)?

Equivalent to put(item, block=False), provided for compatibility with Queue.put_nowait().

SimpleQueue.get(block=True, timeout=None)?

從隊列中移除并返回一個(gè)項目。如果可選參數 block 是 true 并且 timeout 是 None (默認值)，則在必要時(shí)阻塞至項目可得到。如果 timeout 是個(gè)正數，將最多阻塞 timeout 秒，如果在這段時(shí)間內項目不能得到，將引發(fā) Empty 異常。反之 (block 是 false) , 如果一個(gè)項目立即可得到，則返回一個(gè)項目，否則引發(fā) Empty 異常 (這種情況下，timeout 將被忽略)。

SimpleQueue.get_nowait()?

相當于 get(False) 。