Python Concurrent ProcessPoolExecutorがRaspberry Pi（アイドルPython 3.4.2）で動作しません

Question

ラズベリー・ピー3（4コア）上で稼働する株価機械学習アプリケーションでマルチプロセッシングを使用しようとしています。

from concurrent import futures 

def some_function(x): 
    return x + 1 

def main_function(some_list): 
    with futures.ProcessPoolExecutor() as executor: 
     results = executor.map(some_function, some_list) 
    return results 

if __name__ == '__main__': 
    print(main_function([1, 2, 3])) 

私はこれを実行すると、私はすぐにプロセスがまだ実行されている、と私はそれを殺すためにかどうかを確認されたというメッセージが出ます：ここでの問題を示しているいくつかのコードがあります。 「OK」を押すかどうかに関係なく、プログラムは結果やエラーを生成しません。

ProcessPoolExecutorをThreadPoolExecutorに変更すると問題が解決され、プログラムはジェネレータオブジェクトを期待どおりに配信します。

Answer 1

あなたは次のようにあなたのロジックを修正する必要があります。

from concurrent import futures 

def some_function(x): 
    return x + 1 

def main_function(some_list): 
    with futures.ProcessPoolExecutor() as executor: 
     results = executor.map(some_function, some_list) 

    return list(results) 

if __name__ == '__main__': 
    print(main_function([1, 2, 3])) 

ProcessPoolExecutor.mapは、結果を取得するために消費される必要がある発電機を返します。上記のロジックは繰り返し処理されません。ジェネレータオブジェクトは何も印刷されません。