どのようにマルチプロセッシング（python）モジュールを間違って使用していますか？

Question

誰かが次のコードが正しく実行されない理由を理解できますか？以前のプロセスが終了すると新しいプロセスが生成されますが、このコードを実行すると自動的にすべてが実行されます。つまり、すべてのジョブレポートは終了していないときに終了し、ウィンドウも開いています。なぜis_alive（）の考えは、実際には真である場合にfalseを返しますか？

import subprocess 
import sys 
import multiprocessing 
import time 

start_on = 33 #'!' 
end_on = 34 
num_processors = 4; 
jobs = [] 

def createInstance(): 
    global start_on, end_on, jobs 
    cmd = "python scrape.py" + " " + str(start_on) + " " + str(end_on) 
    print cmd 
    p = multiprocessing.Process(target=processCreator(cmd)) 
    jobs.append(p) 
    p.start() 
    start_on += 1 
    end_on += 1 
    print "length of jobs is: " + str(len(jobs)) 

def processCreator(cmd): 
    subprocess.Popen(cmd, creationflags=subprocess.CREATE_NEW_CONSOLE) 

if __name__ == '__main__': 
    num_processors = input("How many instances to run simultaneously?: ") 
    for i in range(num_processors): 
     createInstance() 

    while len(jobs) > 0: 
     jobs = [job for job in jobs if job.is_alive()] 
     for i in range(num_processors - len(jobs)): 
      createInstance() 
     time.sleep(1) 

    print('*** All jobs finished ***') 

Answer 1

あなたのコードは、各createInstance()呼び出しで2つのプロセスを生成され、私はそれがis_alive()電話をいじりだと思います。

p = multiprocessing.Process(target=processCreator(cmd)) 

processCreator(cmd)を実行するプロセスが1つ生成されます。次に、subprocess.Popen(cmd, creationflags=subprocess.CREATE_NEW_CONSOLE)は、コマンドを実行する子プロセスを生成します。このサブプロセスは直ちに戻り、親プロセスを返します。

このバージョンでは、multiprocessの使用を削除しても問題ありません。私はすべてのあなたの質問を読んでいないが、あなたはマルチプロセッシングモジュールを見てきました

import subprocess 
import sys 
import time 

start_on = 33 #'!' 
end_on = 34 
num_processors = 4; 
jobs = [] 

def createInstance(): 
    global start_on, end_on, jobs 
    cmd = ["python","scrape.py", str(start_on), str(end_on)] 
    print(str(cmd)) 
    p = subprocess.Popen(cmd, creationflags=subprocess.CREATE_NEW_CONSOLE) 
    jobs.append(p) 
    p.start() 
    start_on += 1 
    end_on += 1 
    print "length of jobs is: " + str(len(jobs)) 

if __name__ == '__main__': 
    num_processors = input("How many instances to run simultaneously?: ") 
    for i in range(num_processors): 
     createInstance() 

    while len(jobs) > 0: 
     jobs = [job for job in jobs if job.poll() is None] 
     for i in range(num_processors - len(jobs)): 
      createInstance() 
     time.sleep(1) 

    print('*** All jobs finished ***')