Pythonでのマルチプロセッシング - 子プロセスの最小数がアクティブであることを保証する

Question

最低限の数の子プロセスがいつでも有効であるようにしたい。現在、以下のように起動します： - 私はこのケースでは新しいワーカーを起動したい

pool = Pool(processes=WORKERS) 
pool.map(worker.run, range(WORKERS)) # pass process a number as its ID 

労働者がエラーのためreturnまたはクラッシュして焼くだろう特定のケースがあります。これはすべて可能ですか？

おかげで、

Answer 1

ここでは、単純な（ダム？）ソリューションです：定期的に、すべての労働者をチェック戻ってきたものをポップし、作業者リスト（Doug Hellmanから借りベースコード）に新しいものを追加します。

import multiprocessing, random, time 

def worker(num): 
    """thread worker function""" 
    time.sleep(random.randint(1,10)) 
    print 'Worker:', num 
    return 

if __name__ == '__main__': 
    jobs = [] 
    for i in range(5): 
     p = multiprocessing.Process(target=worker, args=(i,)) 
     jobs.append(p) 
     p.start() 

    while True: 
     time.sleep(2) 
     for n, p in enumerate(jobs): 
      if not p.is_alive(): 
       jobs.pop(n) 
       i += 1 
       p = multiprocessing.Process(target=worker, args=(i,)) 
       jobs.append(p) 
       p.start() 

は、