Python 中的进程通信

Question

在Python中两个进程之间建立通信的最佳方法是什么？经过一番谷歌搜索后，我尝试这样做：

parent_pipe, child_pipe = Pipe()
p = Process(target = instance_tuple.instance.run(), \
    args = (parent_pipe, child_pipe,))
p.start()

向子进程发送数据：

command = Command(command_name, args)
parent_pipe.send(command)

进程目标函数：

while True:
    if (self.parent_pipe.poll()):
        command = parent_pipe.recv()
        if (command.name == 'init_model'):
            self.init_model()
        elif (command.name == 'get_tree'):
            tree = self.get_fidesys_tree(*command.args)
            result = CommandResult(command.name, tree)
            self.child_pipe.send(result)
        elif(command.name == 'set_variable'):
            name = command.args[0]
            value = command.args[1]
            self.config[name] = value

但它似乎不起作用（子进程没有通过parent_pipe接收任何内容）。我该如何修复它？

提前致谢。

Answer 1

您可以在这里查看：http://docs.python。 org/library/multiprocessing.html#exchang-objects- Between-processes
该解决方案与您的解决方案接近，但似乎更容易。

Answer 2

如果我理解文档，在子进程中，您应该从管道的子部分读取。

# Process Target function

while True:
        # poll(None) because you don't want to go through the loop fast between commands
        if (self.child_pipe.poll(None)):    
            command = child_pipe.recv()
            if (command.name == 'init_model'):
                self.init_model()
            elif (command.name == 'get_tree'):
                tree = self.get_fidesys_tree(*command.args)
                result = CommandResult(command.name, tree)
                self.child_pipe.send(result)
            elif(command.name == 'set_variable'):
                name = command.args[0]
                value = command.args[1]
                self.config[name] = value