Python multiprocessing fork子进程无法读取更新后全局变量问题

别慌，你遇到的问题根源在于进程创建的时机和fork的内存复制机制，咱们一步步拆解清楚：

问题核心：进程池创建早于全局变量更新 #

先看你start()函数里的代码顺序：

pool = ctx.Pool()  # 这里已经fork出了进程池的子进程
number = 42        # 这是在fork之后才修改的全局变量

当你调用ctx.Pool()时，系统已经基于当前父进程的内存状态fork出了子进程——此时number还是主进程一开始设置的69。之后主进程把number改成42，但fork出来的子进程和主进程拥有完全独立的内存空间，根本看不到这个后续的修改。

简单说：fork会复制父进程fork瞬间的所有内存副本，之后父子进程的内存修改互不影响。

解决方案 #

方案1：调整顺序，先更新变量再创建进程池

把start()里的代码调换顺序，确保变量更新完成后再fork子进程：

def start():
    global logger
    logger = logging.getLogger('app')
    ctx = get_context('fork')
    global queue
    queue = ctx.Queue()
    consoleHandler = logging.StreamHandler()
    logger.addHandler(consoleHandler)
    logger.setLevel(logging.DEBUG)
    
    # 先更新全局变量，再创建进程池
    global number
    number = 42
    
    global pool
    pool = ctx.Pool()  # 此时fork的子进程会继承number=42的状态

这样子进程启动后就能读到正确的number=42了。

方案2：放弃全局变量，用参数传递（更推荐）

全局变量在多进程+Flask的场景下很容易踩坑（Flask的上下文和全局对象本身就和请求绑定，多进程下状态易混乱）。更稳妥的方式是把需要的变量作为参数传给任务函数：

# 修改task函数，接收number参数
def task(steps, number):
    logger = logging.getLogger('app')
    global queue
    logger.addHandler(QueueHandler(queue))
    logger.setLevel(logging.DEBUG)
    process = current_process()
    logger.info(f'Child {process.name} starting. ppid: {getppid()}, pid:{getpid()}')
    # 直接使用传入的number，不再依赖全局变量
    logger.info(f'Child {process.name} number is:{number} :)')
    # ... 其余代码保持不变

# 修改work函数，传递number参数
def work(taskCount = 5, steps=3):
    fakemap = []
    global number
    for i in range(taskCount):
        fakemap.append(pool.apply_async(task, args=(steps, number, )))
    for result in fakemap:
        print(result.get())

这种方式逻辑更清晰，也避免了全局变量带来的不确定性，特别适合你后续在Flask中使用的场景。

针对你的Flask场景补充建议 #

1. 不要在请求处理中创建进程池：最好在Flask app启动时就初始化好进程池，避免重复创建销毁带来的性能损耗。
2. 日志队列提前初始化：日志队列同样建议在app启动时创建，fork上下文下子进程会自动继承队列对象，无需额外处理。
3. 动态配置用共享机制：如果后续需要动态更新子进程的配置，别用全局变量，改用multiprocessing.Value/Array这类共享内存对象，或者通过消息队列传递。

备注：内容来源于stack exchange，提问作者Voxnihl