python - 在 Python 中实现多处理进程的超时

Question

我愿意:

import multiprocessing as mp
q = mp.Queue()
p = mp.Process(target=lambda x: x, args=('foo',))
p.start()
p.join(10)
if p.exitcode == 0:
   q.get()
else:
   print("We timed out.")

我期望我的小 x->x 函数最多会阻塞 10 秒。如果在那之前完成，我会比那更早得到结果。如果花费的时间比这更长(显然不是在这个玩具示例中，而是在其他情况下)，那么该过程将在 10 秒后终止，我可以检查 exitcode 以确定我们确实超时了。

但是当我执行这段代码时，发生的事情是 q.get() 永远运行。为什么会出现这种情况？

Answer 1

q.get() 永远运行，因为它默认会阻塞，并且您永远不会将任何内容放入队列中。

您可以使用q.get(block=False)或q.get_nowait()(与前者等效)。但请记住，它会引发 queue.Empty，因此您应该处理该问题。