python多进程类内部回调函数

python多进程中，如果回调函数需要写类的属性，那么该类的属性应该设置为多进程共享变量，否则在回调函数中将无法写入该类变量，其余函数访问到的数据仍然是该回调函数写入之前的数据。

不同的进程默认有自己独立的内存空间，互相之间不能直接访问。所以，通常的全局变量或者传递参数，在创建新进程时，都是拷贝一份到新进程里使用。

import multiprocessing
#截取的部分代码   截取的部分代码    截取的部分代码
class Moudle(object):
    control_flag=multiprocessing.Value("i",-1)#多进程共享变量
    #control_flag=-1#这种写法是有问题的，在多进程情况下无法修改该变量的值
    def on_message(self,client, userdata, msg):#回调函数返回消息时调用该方法
        self.control_flag.value = msg.data['index']
        #self.control_flag=msg.data['index']#这种写法是有问题的，在多进程情况下无法修改该变量的值
        print("control_flag",self.control_flag)

#截取的部分代码   截取的部分代码    截取的部分代码
class Env(gym.Env):
    def __init__(self, name):
        self.mqtt_util=Moudle()
    
    def step():
        """
        程序逻辑
        """

import multiprocessing
from environment import Env
os.environ["OMP_NUM_THREADS"] = "1"

class Worker(mp.Process):
    def __init__(self):  #
        super(Worker, self).__init__()
        self.env = Env(0)

    def run(self):
        for i in range(100):
            done = self.env.step()
            while not done:
                 done =self.env,step()

if __name__ == "__main__":
    workers = [Worker()for i in range(1)]
    [w.start() for w in workers]

参考文献
multiprocessing中的共享变量

赏

谢谢你请我吃糖果

微信