Python多进程共享列表对象修改结果不符合预期，子进程修改后父进程无法获取更新值求助

嘿，这个问题我之前刚踩过一模一样的坑！核心原因就是Python多进程的内存隔离机制，咱们一步步拆解来看：

为什么子进程的修改主进程看不到？ #

Python的多进程（基于multiprocessing模块）在创建子进程时，会为每个子进程复制一份父进程的内存空间副本——注意是完全独立的副本，不是共享内存。

放到你的代码里来说：

• 主进程初始化了best_list = []，把它传给Consumer的构造函数
• 当你调用c.start()启动子进程时，子进程会把这个空列表复制到自己的内存里，之后子进程里的self.best_list和主进程的best_list就完全是两个互不相干的对象了
• 子进程run方法里不断追加元素，只是在修改自己的那个列表副本，主进程的原列表根本没被触碰过
• 哪怕你调用c.get_best_list()，返回的也是主进程里Consumer对象持有的那个初始空列表，因为子进程对self.best_list的修改不会同步回主进程的对象属性

怎么解决这个问题？ #

你需要用multiprocessing模块提供的进程安全的共享数据结构，最常用的就是Manager.list()，它底层是通过进程间通信（IPC）来实现多进程共享数据的。

修改你的代码如下：

import multiprocessing

class Consumer(multiprocessing.Process):
    def __init__(self, best_list, task_queue):
        multiprocessing.Process.__init__(self)
        self.best_list = best_list
        self.task_queue = task_queue
    def get_best_list(self):
        return self.best_list
    def run(self):
        proc_name = self.name
        while True:
            next_task = self.task_queue.get()
            answer = next_task()
            if answer != '' and answer != []:
                self.best_list += answer
                print(self.best_list)
            # 一定要标记任务完成，否则join会一直阻塞
            self.task_queue.task_done()

class Task:
    def __call__(self):
        return [100]

# 用Manager创建共享列表
best_list = multiprocessing.Manager().list()
tasks = multiprocessing.JoinableQueue()

for i in range(100):
    tasks.put(Task())

c = Consumer(best_list, tasks)
c.start()
tasks.join()
print(c.get_best_list())
print(best_list)

另外还有个小细节：你的原代码里没调用task_done()，这会导致tasks.join()一直阻塞，我也一起补上了。

其他可选方案 #

如果你不想用共享列表，也可以用Queue来传递结果：

1. 子进程把计算好的answer放到一个结果队列里
2. 主进程在所有任务完成后，从结果队列里取出所有数据，合并到自己的列表中

这种方式有时候更灵活，尤其是当你不需要实时共享数据，只需要最终汇总结果的时候。

排查思路总结 #

以后遇到多进程数据不同步的问题，先从这几点入手：

• 立刻想到多进程的内存隔离特性，这是和多线程最核心的区别
• 检查是否用了普通的Python数据结构（list/dict等），这些在多进程里都是独立副本，修改不会跨进程生效
• 确认是否使用了multiprocessing提供的共享数据结构（Manager下的各类结构、Array、Value等），或者用IPC机制（Queue/Pipe）来传递数据

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