能否将multiprocessing.Pool设为非守护进程？是否存在安全风险？

为什么会报AssertionError: daemonic processes are not allowed to have children？ #

Python的multiprocessing.Pool默认创建的是守护进程，这类进程设计为随主进程退出自动终止，而Python明确禁止守护进程创建子进程——这就是你在task里再开子Pool时触发报错的原因。

能不能把池进程设为非守护进程？安全吗？ #

可以这么做，但非常不推荐，主要有两个核心风险：

• 主进程退出时，非守护进程不会自动终止，容易残留僵尸进程，持续占用CPU、内存等系统资源；如果任务涉及大量非守护进程，没做好清理的话，会导致资源泄漏问题。
• 嵌套的非守护进程层级越多，进程生命周期的管理复杂度越高，一旦某个子进程出现异常，可能牵连整个进程树，排查和修复问题的成本会大幅提升。

更稳妥的替代方案 #

1. 扁平化任务结构，统一用顶层Pool管理 #

把task里嵌套的update任务全部提到顶层，一次性提交给主Pool处理，彻底避免进程嵌套。比如可以把每个task的200次循环里的update任务拆解出来，统一调度：

# 重构task，移除嵌套Pool逻辑
def task_flattened(args):
    ...
    # 先收集所有需要执行的update任务参数
    all_update_args = []
    current_arrays = self.arraies.copy()
    for i in range(200):
        # 这里保留原有的evaluation逻辑
        ...
        # 收集当前轮次的update参数
        all_update_args.extend([[..., a] for a in current_arrays])
        # 如果需要实时更新数组，也可以分批次提交后更新
        # 比如每轮单独提交给顶层Pool处理（如果顶层Pool是全局可访问的）
        # current_arrays = list(global_pool.map(update, [[..., a] for a in current_arrays]))
    ...
    return result

2. 若必须嵌套，严格管控子进程生命周期 #

如果确实需要在task内部并行处理，非要开子Pool，可以实现自定义的非守护进程池，但必须严格做好进程清理：

# 实现非守护进程池
class NonDaemonPool(multiprocessing.pool.Pool):
    def Process(self, *args, **kwds):
        proc = super().Process(*args, **kwds)
        proc.daemon = False
        return proc

# 在task里使用并强制清理
def task(args):
    ...
    for i in range(200):
        # evaluations
        ...
        with NonDaemonPool(len(self.arraies)) as p:
            self.arraies = list(p.map(update, [[..., a] for a in self.arraies]))
        # 强制关闭并等待子进程全部退出
        p.close()
        p.join()
    ...
    return result

这种方式一定要谨慎，必须确保每轮子Pool都完成清理，避免资源泄漏。

3. 改用手动创建非守护进程 #

如果嵌套Pool的需求不可避免，也可以在task里用multiprocessing.Process手动创建非守护进程，逐个管理进程的启动、结果收集和终止，虽然代码量增加，但进程生命周期的可控性更强。

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