在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.
这篇关于Python中的进程通信的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持html5模板网!
Python 多处理模块的 .join() 方法到底在做什么?What exactly is Python multiprocessing Module#39;s .join() Method Doing?(Python 多处理模块的 .join() 方法到底在做什么?)
在 Python 中将多个参数传递给 pool.map() 函数Passing multiple parameters to pool.map() function in Python(在 Python 中将多个参数传递给 pool.map() 函数)
multiprocessing.pool.MaybeEncodingError: 'TypeError("multiprocessing.pool.MaybeEncodingError: #39;TypeError(quot;cannot serialize #39;_io.BufferedReader#39; objectquot;,)#39;(multiprocessing.pool.MaybeEnc
Python 多进程池.当其中一个工作进程确定不再需要Python Multiprocess Pool. How to exit the script when one of the worker process determines no more work needs to be done?(Python 多进程池.当其中一
如何将队列引用传递给 pool.map_async() 管理的函数How do you pass a Queue reference to a function managed by pool.map_async()?(如何将队列引用传递给 pool.map_async() 管理的函数?)
与多处理错误的另一个混淆,“模块"对象没yet another confusion with multiprocessing error, #39;module#39; object has no attribute #39;f#39;(与多处理错误的另一个混淆,“模块对象