來自multiprocessing中multiprocessing.Queue（）的返回值Python

Question

我運行一個簡單的多進程程序（下面的代碼）。我只做2個處理器，然後初始化一個隊列來存儲結果。

我想知道爲什麼用同名q，但每次打印出不同的值。 我知道隊列存儲2返回值，從pro1和pro2。但我所料，這是這樣的：

q = [1,2] 

或

q=[2,1] #depend on which one runs first 

我無法弄清楚如何一個變量q可以是1或2

這讓我很困惑。 謝謝。

代碼：

import multiprocessing 


def run(ID, q): 
    print("Starting thread %s " % (ID)) 

    q.put(ID) 
    return None 

if __name__ == '__main__': 
    q = multiprocessing.Queue() #store the result 
    pro1 = multiprocessing.Process(target=run, args=(1,q)) 
    pro2 = multiprocessing.Process(target=run, args=(2,q)) 

    pro1.start() 
    pro2.start() 

    pro1.join() 
    pro2.join() 

    print("q is ", q.get()) 
    print("another q is ", q.get()) 

結果：

Starting thread 2 
Starting thread 1 
('q is ', 1) 
('another q is ', 2) 

Answer 1

我不是100％肯定你感到困惑準確，但這裏是我認爲這將有助於，但請糾正我，如果我脫軌。你的隊列有兩個進程的輸出。你剛剛獲得第一個完成的那個。

例如，在你的情況下，它看起來像過程首先1點結束，然後處理2

因此後兩個進程都完成隊列會像

[1,2] 

然後當你調用q.get()你得到1現在排隊的樣子：

`[2]` 

然後，當你再次調用q.get()你會得到2，現在隊列是空的。