Les variables d'instance ne sont pas partagées entre les processus en Python

Contenu de la question

J'ai un gros problème avec le multitraitement. Dans ce cas, j'ai un

1. Classe principale dans le processus principal

2. Classe foo dans un autre processus

Je dois modifier certaines variables dans process2 en utilisant le processus principal. Comment puis-je faire ceci/? ? ?

class Main:
     def __init__(self):
          self.Foo_Instance = Foo()
          multiprocessing.Process(target=self.Foo_Instance.do_something).start()

     def Change_Foo(self):
          Foo_Instance.ImportantVar = True
    
class Foo:
     def __init__(self):
          self.ImportantVar = False

     def do_something(self):
          pass

Main_Instance = Main()
Main_Instance.Change_Foo()

Bonne réponse

Chaque processus a généralement sa propre mémoire à laquelle aucun autre processus n'a accès. Si vous souhaitez qu'un processus puisse modifier une variable utilisée par un autre processus, la solution la plus simple consiste à créer la variable dans la mémoire partagée. Dans la démo ci-dessous, nous utilisons multiprocessing.value一个>实例。为了证明 main.change_foo 可以修改 foo 的 importantvar 属性，我们必须在 main.change_foo 修改它之前给 foo.do_something 一个打印出其初始值的机会。同样， foo.do_something 需要等待 main.change_foo pour modifier la valeur afin d'imprimer la valeur mise à jour. Pour y parvenir nous utilisons deux instances 'multiprocessing.event' :

import multiprocessing
import ctypes
import time

class main:
    def __init__(self):
        self.foo_instance = foo()
        multiprocessing.process(target=self.foo_instance.do_something).start()

    def change_foo(self):
        # wait for foo.do_something to have printed out its initial value:
        self.foo_instance.initial_print_event.wait()

        # modify the attribute (add missing self):
        self.foo_instance.importantvar.value = true

        # show that we have modified the attribute:
        self.foo_instance.changed_event.set()


class foo:
    def __init__(self):
        self.importantvar = multiprocessing.value(ctypes.c_bool, false, lock=false)
        self.initial_print_event = multiprocessing.event()
        self.changed_event = multiprocessing.event()

    def do_something(self):
        print('do_something before:', self.importantvar.value)
        # show that we have completed printing our initial value:
        self.initial_print_event.set()

        # now wait for main.change_foo to have changed our variable:
        self.changed_event.wait()

        print('do_something after:', self.importantvar.value)


# required for windows:
if __name__ == '__main__':
    main_instance = main()
    main_instance.change_foo()

Impression :

do_something before: False
do_something after: True

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!