这个Python类变量作用域行为是完全意想不到的，而且很奇怪。这是怎么回事？

Question

好吧，这其中有我撕裂我的头发：

我有一个多进程的程序，有独立的工人在每一个给定的任务工作。

当KeyboardInterrupt出现时，我希望每个工作人员将其内部状态保存到一个文件中，以便它可以继续下一次停止的位置。

无论其...

它看起来像它包含关于在此之前可能发生的状态消失信息字典！

怎么样？ exit（）函数正在访问更多的全局范围版本的字典......事实证明，各种run（）（和从属于run（））函数已经创建了它们自己的变量版本。

没什么奇怪有关...

除...

他们都已经使用了自我。关键词。

其中，如果我的理解是正确的，应该意味着他们总是访问变量的实例范围版本...不创建它们自己的！

下面的代码的简化版本：

import multiprocessing 
import atexit 
import signal 
import sys 
import json 

class Worker(multiprocessing.Process): 
    def __init__(self, my_string_1, my_string_2): 
     # Inherit the __init_ from Process, very important or we will get errors 
     super(Worker, self).__init__() 
     # Make sure we know what to do when called to exit 
     atexit.register(self.exit) 
     signal.signal(signal.SIGTERM, self.exit) 
     self.my_dictionary = { 
      'my_string_1' : my_string_1, 
      'my_string_2' : my_string_2 
      } 
    def run(self): 
     self.my_dictionary = { 
      'new_string' : 'Watch me make weird stuff happen!' 
      } 
     try: 
      while True: 
       print(self.my_dictionary['my_string_1'] + " " + self.my_dictionary['my_string_2']) 
     except (KeyboardInterrupt, SystemExit): 
      self.exit() 
    def exit(self): 
     # Write the relevant data to file 
     info_for_file = { 
      'my_dictionary': self.my_dictionary 
      } 
     print(info_for_file) # For easier debugging 
     save_file = open('save.log', 'w') 
     json.dump(info_for_file, save_file) 
     save_file.close() 
     # Exit 
     sys.exit() 

if __name__ == '__main__': 
    strings_list = ["Hello", "World", "Ehlo", "Wrld"] 
    instances = [] 
    try: 
     for i in range(len(strings_list) - 2): 
      my_string_1 = strings_list[i] 
      my_string_2 = strings_list[i + 1] 
      instance = Worker(my_string_1, my_string_2) 
      instances.append(instance) 
      instance.start() 
     for instance in instances: 
      instance.join() 
    except (KeyboardInterrupt, SystemExit): 
     for instance in instances: 
      instance.exit() 
      instance.close() 

上运行，我们得到以下回溯...

Process Worker-2: 
Process Worker-1: 
Traceback (most recent call last): 
    File "/usr/lib/python3.5/multiprocessing/process.py", line 249, in _bootstrap 
    self.run() 
Traceback (most recent call last): 
    File "/usr/lib/python3.5/multiprocessing/process.py", line 249, in _bootstrap 
    self.run() 
    File "<stdin>", line 18, in run 
    File "<stdin>", line 18, in run 
KeyError: 'my_string_1' 
KeyError: 'my_string_1' 

换句话说，即使在被明确添加的关键my_string_1 init，run（）函数正在访问self.my_dictionary的新版本，该版本不包含该密钥！

同样，如果我们用一个普通变量处理（my_dictionary而不是self.my_dictionary），但我认为self.variables总是实例范围，这将有望...

这到底是怎么回事？

Answer 1

你的问题基本上可以由以下表示：

class Test: 
    def __init__(self): 
     self.x = 1 

    def run(self): 
     self.x = 2 

     if self.x != 1: 
      print("self.x isn't 1!") 

t = Test() 
t.run() 

注意什么run在做什么。

您有不兼容的数据覆盖您的实例成员self.my_dictionary当你写

self.my_dictionary = { 
      'new_string' : 'Watch me make weird stuff happen!' 
} 

然后尝试使用不兼容的数据时，你说

print(self.my_dictionary['my_string_1']... 

这不正是明确你的目的是什么，当你覆盖my_dictionary，但这就是为什么你会收到错误。你需要重新思考你的逻辑。