マルチプロセッシングでstart（）とrun（）の属性を更新する方法

Question

マルチプロセッシングからサブクラスを作成します。

オブジェクトp.run（）はlong_runtime_procからinstance.ret_valueを更新できますが、p_start（）はlong_runtime_procが呼び出されて実行されてもret_valueを更新できません。

p.start（）でret_valueを取得するにはどうすればよいですか？直接Process.run()を呼び出す

*class myProcess (multiprocessing.Process): 
    def __init__(self, pid, name, ret_value=0): 
     multiprocessing.Process.__init__(self) 
     self.id = pid 
     self.ret_value = ret_value 
    def run(self): 
     self.ret_value = long_runtime_proc (self.id)* 

Answer 1

が新しいプロセスを開始しない、Process.run()にすなわちコードは、それを呼び出し同じプロセスで実行されます。そのため、self.ret_valueへの変更が有効です。ただし、Process.run()に直接電話することはできません。

新しい子プロセスが作成され、その後、Process.run()のコードは、この新しいプロセスでを実行するProcess.start()でサブプロセスを開始します。 long_runtime_procの戻り値をself.ret_valueに割り当てると、これは子プロセスで発生します。親ではないため、親のret_vauleは更新されません。

パイプまたはキューを使用して親プロセスに戻り値を送信する必要があります。詳細は、documentationを参照してください。ここでは、キューを使用した例です。

import time 
import multiprocessing 

def long_runtime_proc(): 
    '''Simulate a long running process''' 
    time.sleep(10) 
    return 1234 

class myProcess(multiprocessing.Process): 
    def __init__(self, result_queue): 
     self.result_queue = result_queue 
     super(myProcess, self).__init__() 

    def run(self): 
     self.result_queue.put(long_runtime_proc()) 

q = multiprocessing.Queue() 
p = myProcess(q) 
p.start() 
ret_value = q.get() 
p.join() 

このコードret_valueでrepyのための1234