2011-08-18 16 views
12

Pythonで2つのプロセス間の通信を確立する最良の方法は何ですか?いくつかのグーグルの後、私はそうしてみました:Pythonでのプロセス通信

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

処理対象機能:子プロセスにデータを送信する

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

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を通して何も受け取らない)。どうすれば修正できますか?

ありがとうございます。

+0

parent_pipeを確認してください。インスタンス化されていますか? – krs1

+0

@ krs1はい、子プロセスと親プロセスの両方のパイプがインスタンス化されます。 –

答えて

5

ここで見ることができます:http://docs.python.org/library/multiprocessing.html#exchanging-objects-between-processes 解決策はあなたに近いですが、もっと簡単です。

+0

問題は、この解決策が何らかの理由で私のために機能しないことです。データは送信されますが、パイプからは何も読み込めません。 –

+0

問題はプロセスのインスタンス化にあると思います。パラメータ 'target'は、関数をパイプの終わりにリンクするために使用されます。 – Tom97531

0

ドキュメントを理解している場合、子プロセスではパイプの子部分から読み込む必要があります。

# 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