import queue import time import threading import random   q=queue.Queue(5)  #生產者 def pr():   name=threading.current_thread().getName()   print(name+"線程啟動......")   for i in range(100):     t=random.randint(2,9)     print(name,"睡眠時間: ",t)     time.sleep(t);     d="A"+str(i)     print(name+"正在存第",i+1,"個數據: ",d)     #q.put("A"+str(i),False,2000)     q.put(d)   print("生產完畢!")   #消費者 def co():   name=threading.current_thread().getName()   time.sleep(1)   print(name+"線程啟動......")    while True:     print(name+"檢測到隊列數量: ",q.qsize())     t=random.randint(2,9)     print(name,"睡眠時間: ",t)     data=q.get();     print(name+"消費一個數據: ",data)     p=threading.Thread(target=pr,name="生產者") c=threading.Thread(target=co,name="消費者1") c2=threading.Thread(target=co,name="消費者2")  p.start() c.start() c2.start() 

生產者線程啟動...... 生產者 睡眠時間: 4 消費者1線程啟動...... 消費者1檢測到隊列數量: 0 消費者1 睡眠時間: 2 消費者2線程啟動...... 消費者2檢測到隊列數量: 0 消費者2 睡眠時間: 3 生產者正在存第 1 個數據: A0 生產者 睡眠時間: 9 消費者1消費一個數據: A0 消費者1檢測到隊列數量: 0 消費者1 睡眠時間: 8 生產者正在存第 2 個數據: A1 生產者 睡眠時間: 5 消費者2消費一個數據: A1 消費者2檢測到隊列數量: 0 消費者2 睡眠時間: 7 生產者正在存第 3 個數據: A2 生產者 睡眠時間: 8 消費者1消費一個數據: A2 消費者1檢測到隊列數量: 0 消費者1 睡眠時間: 2 生產者正在存第 4 個數據: A3 生產者 睡眠時間: 7 消費者2消費一個數據: A3 消費者2檢測到隊列數量: 0 消費者2 睡眠時間: 9 生產者正在存第 5 個數據: A4 生產者 睡眠時間: 2 消費者1消費一個數據: A4 消費者1檢測到隊列數量: 0 消費者1 睡眠時間: 5 生產者正在存第 6 個數據: A5 生產者 睡眠時間: 5 消費者2消費一個數據: A5 消費者2檢測到隊列數量: 0 消費者2 睡眠時間: 6 生產者正在存第 7 個數據: A6 生產者 睡眠時間: 7 消費者1消費一個數據: A6 消費者1檢測到隊列數量: 0 消費者1 睡眠時間: 7 生產者正在存第 8 個數據: A7 生產者 睡眠時間: 3 消費者2消費一個數據: A7 消費者2檢測到隊列數量: 0 消費者2 睡眠時間: 8 生產者正在存第 9 個數據: A8 生產者 睡眠時間: 2 消費者1消費一個數據: A8 消費者1檢測到隊列數量: 0 消費者1 睡眠時間: 4 生產者正在存第 10 個數據: A9 生產者 睡眠時間: 4 消費者2消費一個數據: A9 消費者2檢測到隊列數量: 0 消費者2 睡眠時間: 5 生產者正在存第 11 個數據: A10 生產者 睡眠時間: 2 消費者1消費一個數據: A10 消費者1檢測到隊列數量: 0 消費者1 睡眠時間: 3 生產者正在存第 12 個數據: A11 生產者 睡眠時間: 3 消費者2消費一個數據: A11 消費者2檢測到隊列數量: 0 消費者2 睡眠時間: 3 生產者正在存第 13 個數據: A12 生產者 睡眠時間: 3 消費者1消費一個數據: A12 消費者1檢測到隊列數量: 0 消費者1 睡眠時間: 3 生產者正在存第 14 個數據: A13 生產者 睡眠時間: 8 消費者2消費一個數據: A13 消費者2檢測到隊列數量: 0 消費者2 睡眠時間: 7 生產者正在存第 15 個數據: A14 生產者 睡眠時間: 3 消費者1消費一個數據: A14 消費者1檢測到隊列數量: 0 消費者1 睡眠時間: 7 生產者正在存第 16 個數據: A15 生產者 睡眠時間: 2 消費者2消費一個數據: A15 消費者2檢測到隊列數量: 0 消費者2 睡眠時間: 9 

Queue.qsize() 返回隊列的大小  Queue.empty() 如果隊列為空，返回True,反之False  Queue.full() 如果隊列滿了，返回True,反之False Queue.full 與 maxsize 大小對應  Queue.get([block[, timeout]])獲取隊列，timeout等待時間  Queue.get_nowait() 相當Queue.get(False) 非阻塞 Queue.put(item) 寫入隊列，timeout等待時間  Queue.put_nowait(item) 相當Queue.put(item, False) Queue.task_done() 在完成一項工作之后，Queue.task_done()函數向任務已經完成的隊列發送一個信號 Queue.join() 實際上意味著等到隊列為空，再執行別的操作