Saya menghadapi masalah besar dengan multiprocessing. Dalam kes ini saya mempunyai
1. Kelas utama dalam proses utama
2. Kelas foo dalam proses lain
Saya perlu menukar beberapa pembolehubah di dalam proses2 menggunakan proses utama. Bagaimanakah saya boleh melakukan ini/? ? ?
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()
Setiap proses biasanya mempunyai ingatan tersendiri yang tidak boleh diakses oleh mana-mana proses lain. Jika anda mahu satu proses boleh mengubah suai pembolehubah yang sedang digunakan oleh proses lain, penyelesaian paling mudah ialah mencipta pembolehubah dalam memori dikongsi. Dalam demo di bawah, kami menggunakan multiprocessing.value
一个>实例。为了证明 main.change_foo
可以修改 foo
的 importantvar
属性,我们必须在 main.change_foo
修改它之前给 foo.do_something
一个打印出其初始值的机会。同样, foo.do_something
需要等待 main.change_foo
untuk menukar nilai untuk mencetak nilai yang dikemas kini. Untuk mencapai matlamat ini, kami menggunakan dua kejadian '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()
Cetakan:
do_something before: False do_something after: True
Atas ialah kandungan terperinci Pembolehubah contoh tidak dikongsi antara proses dalam Python. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!