多进程Python中multiprocessing. queue()的返回值

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，现在队列是空的。