Python multiprocessing.Process 子类的属性

Question

我有两个要相互通信的进程：

文件 hwmgr.py：

import multiprocessing as mp
from setproctitle import setproctitle
import smbus
import myLoggingModule as log

class HWManager(mp.Process):
    def __init__(self):
        mp.Process.__init__(self)
        self.i2c_lock = mp.Lock()
    def run(self):
        setproctitle('hwmgr')
        # self.logger = log.config_logger(**kwargs)
    def get_voltage(self):
        with self.i2c_lock:
            # ...do i2c stuff to get a voltage with smbus module
        # self.logger.debug('Got a voltage: %s', voltage)
        return voltage

文件 main.py：

import hwmgr

hwm = hwmgr.HWManager()
hwm.start()

battery = hwm.get_voltage()

print battery  # Works!

因此，有趣的是，按预期工作 - 电压由方法调用返回，无需任何特殊的多处理魔法。 但是，如果我启用涉及记录器的两行，当遇到 logger.debug() 调用时，我会得到：

AttributeError: 'HWManager' object has no attribute 'logger'

而且，事实上，如果我在那里打印一个dir(self)，它就没有logger。
我不明白吗？我的记录器去哪儿了？

记录器在run()方法中定义的原因，而不是__init__()是因为我在新进程的根记录器之后，因为记录器的文件名取自新进程标题 (getproctitle()) 直到进程在完成__init__() 方法后才能调用——当然，这部分可能有另一种方法，但我还没有找到它。 ..

WIP 代码：
我已删除对日志记录模块的引用 - 属性是什么并不重要。
如果您注释掉 print houdiniAttribute 行，一切都会按预期工作
需要明确的是，传递一个 return int 是有效的 - 消失的属性是问题

文件 hwmgr.py：

import multiprocessing as mp
from setproctitle import setproctitle
import smbus

class HWManager(mp.Process):
    def __init__(self):
        mp.Process.__init__(self)
        self.i2c_lock = mp.Lock()

    def run(self):
        setproctitle('hwmgr')
        self.houdiniAttribute = 'ASDFGHJKL'
        with self.i2c_lock:
            pass  # Set up I2C bus to take ADC readings

        while True:  # Doesn't matter if this is here...
           pass

    def get_voltage(self):
        with self.i2c_lock:
            voltage = 12.0  # Actually, do i2c stuff to get a voltage with smbus module
        print self.houdiniAttribute
        return voltage

文件client.py：

import multiprocessing as mp
from setproctitle import setproctitle
from time import sleep

class HWClient(mp.Process):
    def __init__(self, hwm):
        mp.Process.__init__(self)
        self.hwm = hwm

    def run(self):
        setproctitle('client')
        while True:
            battery = self.hwm.get_voltage()
            print battery
            sleep(5)

文件 main.py：

import hwmgr
import client

hwm = hwmgr.HWManager()
hwm.start()
cl = client.HWClient(hwm)
cl.start()

Answer 1

尝试澄清：

1. 您在进程 1 中创建进程对象 1
2. 进程对象产生一个新进程（进程 2）
3. 在进程 2 中，run() 在同一类的另一个对象（对象 2）上被调用。
4. run() 将属性分配给对象 2。
5. 进程 2 完成并移除对象 2。
6. 进程 1 现在知道进程 2 已完成。对象 1 仍然具有旧属性。

如果您想同步内容，请查看管理器。 Multiprocessing Share Unserializable Objects Between Processes

这能回答你的问题吗？