1.Queue使用方法：

• Queue.qsize()：返回當前佇列包含的訊息數量；
• Queue.empty()：如果佇列為空，返回True，反之False ；
• Queue.full()：如果佇列滿了，返回True,反之False；
• Queue.get():獲取佇列中的一條訊息，然後將其從列隊中移除，可傳參超時時長。
• Queue.get_nowait()：相當Queue.get(False),取不到值時觸發異常：Empty；
• Queue.put():將一個值新增進數列，可傳參超時時長。
• Queue.put_nowait():相當於Queue.get(False),當佇列滿了時報錯：Full。

2.Queue使用例項：

來，上程式碼：

#!/usr/bin/env python3

import time
from multiprocessing import Process,Queue

q = Queue()  #建立列隊，不傳數字表示列隊不限數量
for i in range(11):
    q.put(i)

def A():
    while 1:
        try:
            num = q.get_nowait()
            print('我是程序A,取出數字:%d'%num)
            time.sleep(1)
        except :
            break
 


def B():
    while 1:
        try:
            num = q.get_nowait()
            print('我是程序B,取出數字:%d'%num)
            time.sleep(1)
        except :
            break

p1 = Process(target = A)
p2 = Process(target = B)
p1.start()
p2.start()

此程式是在佇列中加入10個數字，然後用2個程序來取出。

執行結果：

我是程序A,取出數字:0
我是程序B,取出數字:1
我是程序A
 
,取出數字:2
我是程序B,取出數字:3
我是程序A,取出數字:4
我是程序B,取出數字:5
我是程序B,取出數字:6
我是程序A,取出數字:7
我是程序B,取出數字:8
我是程序A,取出數字:9
我是程序B,取出數字:10

3.使用程序池Pool時，Queue會出錯，需要使用Manager.Queue：

上程式碼

#!/usr/bin/env python3

import time
from multiprocessing import Pool,Manager,Queue

q = Manager().Queue()
for i in range(11):
    q.put(i)

def A(i):
    num = q.get_nowait()
    print('我是程序%d,取出數字:%d'%(i,num))
    time.sleep(1)
            

pool = Pool(3)

for i in range(10):
    pool.apply_async(A,(i,))

pool.close()
pool.join()

執行結果：

我是程序1,取出數字:0
我是程序0,取出數字:1
我是程序2,取出數字:2
我是程序4,取出數字:3
我是程序3,取出數字:4
我是程序5,取出數字:5
我是程序6,取出數字:6
我是程序7,取出數字:7
我是程序8,取出數字:8
我是程序9,取出數字:9

• 當把Manager().Queue()直接換成Queue()，可能會出現資源混亂，缺少程序。