多处理池的意外行为

Question

在下面的代码中，我期望输出为 2，因为我在将函数分配给池以进行多处理之前更改了 config 的值，但我得到的是 5。我相信这是有充分理由的，但不知道如何解释。

from multiprocessing import Pool 
config = 5

class Test:

  def __init__(self):
    print("This is init")

  @classmethod
  def testPrint(cls, data):
    print(config)
    print("This is testPrint")
    return config

if __name__ == "__main__" :
  pool = Pool()
  config = 2
  output = pool.map(Test.testPrint, range(10))
  print(output)

输出

from multiprocessing import Pool 
config = 5

class Test:

  def __init__(self):
    print("This is init")

  @classmethod
  def testPrint(cls, data):
    print(config)
    print("This is testPrint")
    return config

if __name__ == "__main__" :
  pool = Pool()
  config = 2
  output = pool.map(Test.testPrint, range(10))
  print(output)

Answer 1

创建池时会创建新进程。之后，.map子进程看不到对父内存空间所做的更改，除了在池函数中传递的内容，如。像 linux 这样的分叉系统会为父内存空间创建写时复制视图 - 并且该写入会为父进程生成一个唯一的内存块，子进程看不到。生成系统重新导入模块（设置全局变量），然后尝试为子进程pickle/unpickle 状态。在这两种情况下，这都在Pool类初始化返回到您的程序之前完成。