Python multiprocessing拆分至多文件后运行异常求助

嘿，我一眼就瞅出问题所在了——你拆分文件后，bar.py里的process_data函数参数没跟上节奏！

核心错误分析 #

你在foo.py里创建进程时，给bar.process_data传了三个参数：(q, "Hello", "World")，但bar.py里的函数定义是def process_data(msg1, msg2):，根本没接收q这个关键参数！结果就是子进程里的q.put()会抛出NameError: name 'q' is not defined的错误，子进程默默崩溃退出，主进程的q.get()就一直傻等，永远拿不到结果。

另外提一句，如果你用的是Windows系统，多进程启动时会重新导入主模块，不过你已经用if __name__ == '__main__':做了保护，这部分是没问题的，不用操心。

修正后的代码 #

先把bar.py的函数改成正确接收参数的版本：

def process_data(q, msg1, msg2 ):
    q.put( [msg1, msg2 ] )

然后foo.py可以保留原来的代码，不过建议加个超时和错误检查，方便以后排查问题：

from multiprocessing import Process, Queue
import bar

if __name__ == '__main__':
    q = Queue()
    p = Process(target=bar.process_data, args=(q, "Hello", "World"))
    p.start()
    
    # 增加超时机制，避免无限阻塞
    try:
        result = q.get(timeout=5)
        print(result)
    except Exception as e:
        print(f"获取结果失败: {e}")
        print(f"子进程是否存活: {'是' if p.is_alive() else '否'}")
        print(f"子进程退出码: {p.exitcode}")  # 非0值说明子进程出错
    
    p.join()

额外排查小技巧 #

以后遇到多进程无响应的情况，可以把子进程的错误信息也放到队列里返回，这样能快速定位问题：
修改bar.py：

def process_data(q, msg1, msg2 ):
    try:
        q.put( [msg1, msg2 ] )
    except Exception as e:
        q.put(f"子进程执行出错: {str(e)}")

这样主进程就能拿到错误信息，而不是一直阻塞了。

内容的提问来源于stack exchange，提问作者o_tschek