Python中的进程通信

2022-01-12 00:00:00 python multiprocessing

问题描述

在python中建立两个进程之间通信的最佳方法是什么?经过一番谷歌搜索,我尝试这样做:

What is the best way to establish communication between two processes in python? After some googling, I tried to do so:

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 接收任何内容).我该如何解决?

But it doesn't seem to work (child process doesn't receive anything through parent_pipe). How can I fix it?

提前致谢.


解决方案

你可以看这里:http://docs.python.org/library/multiprocessing.html#exchanging-objects-between-processes该解决方案与您的解决方案很接近,但似乎更容易.

You can have a look here : http://docs.python.org/library/multiprocessing.html#exchanging-objects-between-processes The solution is close to yours but seems easier.

相关文章