相同多处理代码的不同 O/P

Question

我的代码： 在 repl.it IDE 中运行它

from multiprocessing import Queue

colors = ['red', 'green', 'blue', 'black']
cnt = 1
# instantiating a queue object
queue = Queue()
print('pushing items to queue:')
for color in colors:
    print('item no: ', cnt, ' ', color)
    queue.put(color)
    cnt += 1

print('\npopping items from queue:')
cnt = 1
while not queue.empty():
    print('item no: ', cnt, ' ', queue.get())
    cnt += 1

但是每次我运行它，o/p 每次都不同，这是为什么呢？

1 -

 pushing items to queue:
item no:  1   red
item no:  2   green
item no:  3   blue
item no:  4   black

popping items from queue:
item no:  1   red
item no:  2   green
item no:  3   blue
item no:  4   black

2- 这次它不显示 get o/p

pushing items to queue:
item no:  1   red
item no:  2   green
item no:  3   blue
item no:  4   black

popping items from queue:

3- 这次只有 get() 部分的 2 o/p

pushing items to queue:
item no:  1   red
item no:  2   green
item no:  3   blue
item no:  4   black

popping items from queue:
item no:  1   red
item no:  2   green

为什么会这样！这与我不知道的一些隐藏的多处理有关吗？

提前致谢。

Answer 1

multiprocessing.Queue 是通过使用 线程 实现的。这意味着每次一个项目是put 在某些情况下，例如您的脚本，线程需要拾取，主线程更快，而不是所有项目正在接机。

如果您稍加延迟 (time.sleep(0.5 # for example.)，您会看到它再次正常运行。