2017-03-02 12 views
0

特定の要件を満たすランダムな値のセットを生成しようとしています。Pythonマルチプロセッシングで最初の結果に戻る

私はこれを並列して実行してスピードアップしたいと考えています。つまり、次のようなものです:

pool = multiprocessing.Pool(8) 
pool.map(gen_random_set, [set_size]*8) 

ただし、複数のセットは必要ありません。非常に最初のセットが見つかった後、どのようにしてプールを終了させるのですか(恐らくpool.terminate()を使用します)?ここ

答えて

0

は、終端の例である:

import multiprocessing 
from multiprocessing import Pool 
    def worker(i): 
    time.sleep(3) 
    print(i) 

    mypool = Pool() 
    a = mypool.map_async(worker,range(1000)) 

あなたがこれを実行すると、あなたのプールの実行が停止します。

multiprocessing.pool.Pool.terminate(mypool) 

名「の、MyPool」あなたが作成したプールオブジェクトと同じでなければなりません投稿者mypool = Pool()

関連する問題