在Python中怎样将multiprocessing子进程异常传递给主进程-Python教程-PHP中文网

子进程崩溃时主进程默认收不到异常，需通过Queue、Pipe或Pool的error_callback显式传递；推荐用Queue在子进程中捕获并发送异常信息，主进程join后取值并重新raise。

在python中怎样将multiprocessing子进程异常传递给主进程

子进程崩溃时主进程收不到异常？这是默认行为

multiprocessing 默认不会把子进程的异常传播回主进程。子进程一出错就静默退出，Process.join() 返回后主进程根本不知道它挂了，更别说拿到 traceback。这不是 bug，是设计使然——子进程与主进程内存隔离，异常对象无法直接跨进程传递。

要让主进程感知并处理子进程异常，必须主动捕获、序列化、再反序列化。Python 标准库提供了现成路径，但需要你显式调用。

用 multiprocessing.Queue 传异常信息最稳妥

Queue 是 multiprocessing 中少数能安全跨进程传递 Python 对象的机制之一，支持 Exception 实例（只要它可被 pickle 序列化）。

实操建议：

在子进程中用 try/except 捕获所有异常，把 sys.exc_info() 或 traceback.format_exc() 结果塞进 Queue
主进程在 join() 后立刻从 Queue 尝试取值；若取出的是异常对象，直接 raise 它
别依赖 Queue.get_nowait() —— 可能因调度时序漏掉，改用带超时的 get(timeout=0.1) 并捕获 queue.Empty
确保 Queue 在子进程启动前创建，并作为参数传入 target 函数

示例关键片段：

def worker(q):
    try:
        1 / 0
    except Exception:
        import traceback, sys
        q.put((sys.exc_info()[0], sys.exc_info[1], traceback.format_exc()))
<p>if <strong>name</strong> == '<strong>main</strong>':
q = multiprocessing.Queue()
p = multiprocessing.Process(target=worker, args=(q,))
p.start()
p.join()
if not q.empty():
exc_type, exc_value, exc_tb = q.get()
raise exc_value  # 或 raise exc_type(exc_value).with_traceback(...)
</p>