ProcessPoolExecutor 放进函数后不返回：检查 Can't pickle local object

并行任务单独运行有结果，把 worker 定义移进包装函数后却长时间没有输出。若结果读取处出现 Can't pickle local object，先检查提交的是不是嵌套函数或 lambda；增加进程数和等待时间不会让局部函数自动变得可传输。

下面针对 Python 3 标准库 ProcessPoolExecutor。它使用进程执行任务，提交的可调用对象、参数和返回值都需满足相应的 pickle 要求。交互式环境还有子进程导入入口的限制，不能把“在当前单元格定义了函数”当作完整前提。

包装函数可以保留，worker 要有可导入身份

下面是错误的结构示例：

from concurrent.futures import ProcessPoolExecutor


def run_tasks(values):
    def worker(value):
        return len(value)

    with ProcessPoolExecutor() as pool:
        return list(pool.map(worker, values))

worker 属于 run_tasks 的局部作用域。标准 pickle 传递函数时，主要记录它的模块与限定名称，不会把整个函数代码和闭包内容打包发送。另一个进程需要能从可导入模块中找到那个对象。

把 worker 放到模块顶层，用普通 def 定义；包装函数仍可负责建立进程池、准备参数和收集结果。仅改函数名、给局部变量加 global 声明，或把 lambda 换成另一个局部 def，不等于建立稳定的模块导入路径。

在普通模块中组织入口

下面是可作为普通 .py 文件组织方式的示例，任务只读取字符串长度，没有外部写入。保存为项目中可正常启动、可被子进程导入的模块，再按项目已有方式运行：

from concurrent.futures import ProcessPoolExecutor


def count_chars(text):
    return len(text)


def run_tasks(values):
    with ProcessPoolExecutor(max_workers=2) as pool:
        return list(pool.map(count_chars, values))


if __name__ == "__main__":
    results = run_tasks(["alpha", "beta"])
    print(results)

入口保护让创建进程池的调用留在主动启动时，避免子进程导入模块时再次创建进程。函数定义本身仍在模块顶层；不要把 count_chars 也藏进入口保护或运行时临时定义的作用域。

大型项目可以把 worker 放到独立、可导入的模块。该模块还应避免导入时就启动服务、建立进程池或执行写入任务。使用包入口时，确认主进程和子进程使用的解释器、安装环境与模块路径一致。

ProcessPoolExecutor 的当前文档不支持交互式解释器作为一般运行入口。在 Notebook 中仅把定义挪到另一个单元格，不能保证子进程可导入；应把任务逻辑移到实际模块，并在受支持的入口运行，而不是通过强制 fork 依赖某台机器的已有内存状态。Python 3.14 的默认进程启动方式已不再使用 fork，这类隐含依赖也更容易暴露。

读取结果，才能看见任务错误

只调用 submit 或得到 map 返回的迭代器，不代表任务成功。对于 submit，按任务生命周期读取对应 Future 的 result；对于 map，消费返回的结果迭代器。上面的 list 会读取结果，序列化或任务执行异常因此可以传到调用处。

保留最早的完整异常，区分提交对象无法序列化、参数无法序列化，以及子进程异常退出。没有看到子进程 print 输出，不能单独证明任务卡在计算阶段。

worker 移到顶层后若仍报 pickle 错误，继续检查实际参数和返回值。数据库连接、锁、打开的文件对象等资源不应随意作为任务参数传递；按资源所属进程及库要求重新组织创建和释放，而不是修改私有序列化状态。

任务内部调用提交给同一 ProcessPoolExecutor 的 Executor 或 Future 方法还会有死锁风险。不能把等待主进程结果的逻辑塞进 worker，来解决主进程收集结果的问题。

确认结果与任务副作用

修改前保存原任务入口、worker 和参数组织方式。在独立的小输入上检查 worker 能被导入，所有预期结果都被收集，异常能向调用者传播，再接回实际工作负载。若错误转为业务异常，沿那条异常继续处理，不再反复更改进程数。

实际任务会写数据库或文件时，失败并不保证所有任务都没有执行。记录每项完成状态，按项目已有的幂等与恢复规则决定是否重试，避免为了看见输出而重复提交整个批次。回退代码也不会撤销子进程已经提交的外部修改。