プロセスはPythonマルチプロセスプールで停止できません

Question

私はPythonマルチプロセッシングを使用したプログラムを持っています。私は、メインプログラムで作成されたすべてのプロセスを終了することができますが、メインプログラムは常に戻り値を待っているので停止できません。誰も私にこの問題を解決する方法のいくつかの提案を与えることができますか？次のように

コードスニペット

は：

メインプログラム：私はすべてのために、 "サブ機能を行う" 出力を見ることができる

# doing some other jobs 
result = {.....} # a large dictionary 
print 'done with sub functions' 
return result # if I change it to "return 1", it can finish successfully 

workers = multiprocessing.Pool(4) 
args = [arg1, arg2, arg3, arg4] 
results = workers.map(subfunc, args) 
print "we are in main functions " 

subfunc（*引数） mainで作成されたプロセスは出力されず、 "main関数にあります"。誰も私が問題を理解するのを助けることができますか？

Answer 1

subfuncの結果が返された後も、子プロセスは結果をピックアップしてプロセス間通信を通じてマスタープロセスに送信する必要があります。したがって、サブプロセスが実際に終了する準備が整う前に、「完了」を印刷しています。

"fake"を返すだけで、それが問題であることを確認してから、プロセス間で結果をより迅速に伝達する方法について考えることができます。たとえば、リストの内容によっては、内容を厳密な形式でパッケージ化することも、共有メモリが実行可能なオプションである可能性もあります。