在多处理Python中从multiprocessing.Queue()返回值

2019年7月20日 322次阅读

我运行一个简单的多进程程序(下面的代码).我只做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)

最佳答案 我并不是100％肯定你对此感到困惑,但这是我认为会有所帮助,但如果我偏离轨道,请纠正我.您的队列上有两个进程的输出.你刚刚获得了第一个完成的那个.

例如,在您的情况下,它看起来像进程1首先完成,然后进程2.

因此,在两个进程完成后,队列将如下所示

[1,2]

然后,当你调用q.get()时,你得到1,队列现在看起来像：

`[2]`

然后当你再次调用q.get()时,你将获得2,​​现在队列为空.

点赞