Quy trình giao tiếp bằng Python

Question

Cách tốt nhất để thiết lập giao tiếp giữa hai quy trình trong python là gì? Sau khi một số googling, tôi đã cố gắng để làm như vậy:

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

gửi dữ liệu đến quá trình con:

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

Process mục tiêu chức năng:

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 

Nhưng nó dường như không làm việc (quá trình con không nhận được bất cứ điều gì thông qua parent_pipe). Làm thế nào tôi có thể sửa chữa nó?

Xin cảm ơn trước.

Answer 1

Bạn có thể xem tại đây: http://docs.python.org/library/multiprocessing.html#exchanging-objects-between-processes Giải pháp gần với bạn nhưng có vẻ dễ dàng hơn.

Answer 2

Nếu tôi hiểu tài liệu, trong quá trình con bạn nên đọc từ phần con của đường ống.

# 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