当使用多进程队列时，如果想从队列中获取数据，但队列为空，会抛出Empty异常。常规的解决方法是通过捕获异常来重新尝试获取数据，直到队列不为空为止。

代码示例：

from multiprocessing import Queue, Process import time

消费者进程

def consumer(q): while True: try: item = q.get(timeout=1) print(f"Consumed {item}") except: # 如果队列为空，则等待 1 秒后重新尝试 time.sleep(1) continue

生产者进程

def producer(q): for i in range(10): q.put(i) print(f"Produced {i}") time.sleep(0.5)

if name == 'main': q = Queue() p1 = Process(target=consumer, args=(q,)) p2 = Process(target=producer, args=(q,))

p1.start()
p2.start()

p1.join()
p2.join()

在上面的示例中，使用try-except捕获Empty异常，并等待 1 秒后重新尝试获取数据。同时，为了展示代码逻辑，添加了生产者进程放入 10 个数据到队列中的操作。运行此示例时，可以看到消费者进程从队列中取出 10 个数据并输出。