第一段引用上面的摘要：

本文旨在帮助开发者解决在使用Python多进程multiprocessing.Pool()时遇到的卡死或MapResult对象不可迭代的问题。通过分析常见错误原因，提供简洁有效的解决方案，确保多进程代码能够正确运行，充分利用多核CPU的并行计算能力。核心在于理解主进程与子进程的执行逻辑，并正确使用if __name__ == ‘__main__’:语句。

问题分析

在使用multiprocessing.Pool()时，如果出现程序卡死或者TypeError: ‘MapResult’ object is not iterable的错误，通常是因为以下原因：

1. 代码在顶层执行： multiprocessing模块的工作方式是，它会fork当前进程来创建子进程。这意味着主进程中的顶层代码会被所有子进程执行一遍。如果你的main()函数（或者任何其他包含Pool创建和使用的代码）在顶层执行，每个子进程也会尝试创建自己的Pool，这会导致资源竞争和死锁，进而导致程序卡死。
2. MapResult对象的使用： pool.map_async() 返回的是一个 MapResult 对象，这个对象本身不是一个可迭代对象。你需要调用它的 get() 方法来获取结果列表。如果 get() 方法调用后程序卡死，很可能还是因为第一个原因，即子进程也在尝试调用 get()。

解决方案

核心在于确保只有主进程执行创建和使用Pool的代码。这可以通过使用if __name__ == ‘__main__’:语句来实现。

立即学习“Python免费学习笔记（深入）”；

import multiprocessing as mp  def double(i):     return i * 2  def main():     pool = mp.Pool()     for result in pool.map(double, [1, 2, 3]):         print(result)  if __name__ == '__main__':      main()

代码解释：

GenStore

AI对话生成在线商店，一个平台满足所有电商需求

21

查看详情

• if __name__ == ‘__main__’: 这行代码的作用是判断当前模块是否作为主程序运行。当Python脚本直接被执行时，__name__ 的值会被设置为 ‘__main__’。如果脚本是被导入的，__name__ 的值就是模块名。
• 将 main() 函数放在 if __name__ == ‘__main__’: 块中，可以确保 main() 函数只在主进程中执行，避免子进程重复创建Pool。

使用 pool.map_async()：

如果使用 pool.map_async()，需要调用 result.get() 来获取结果，并同样确保只在主进程中调用。

import multiprocessing as mp  def double(i):     return i * 2  def main():     pool = mp.Pool()     result = pool.map_async(double, [1, 2, 3])     print(result.get())  # 获取结果列表  if __name__ == '__main__':      main()

注意事项：

• 确保所有需要在子进程中执行的函数（例如上面的double()函数）是可以在所有进程中访问的。
• 避免在子进程中修改全局变量，因为每个子进程都有自己的内存空间，修改不会影响到其他进程。如果需要共享数据，可以使用multiprocessing.Value或multiprocessing.Array等。
• 在创建Pool时，可以指定进程的数量。默认情况下，Pool会创建与CPU核心数相同的进程。可以根据实际情况调整进程数量，以达到最佳性能。例如：pool = mp.Pool(processes=4)。

总结

解决Python多进程Pool卡死或MapResult不可迭代问题的关键在于理解multiprocessing模块的工作原理，特别是主进程和子进程的执行逻辑。通过使用if __name__ == ‘__main__’:语句，可以确保只有主进程执行创建和使用Pool的代码，从而避免资源竞争和死锁。同时，正确使用pool.map_async()返回的MapResult对象，调用get()方法获取结果，可以确保多进程代码能够正确运行，充分利用多核CPU的并行计算能力。