我尝试了很多方法来调用我的子进程,以便同时运行它们。它创建所有进程,但一次只运行一个。
我的3个进程通过套接字(multiprocessing.connection.Listener/Client)与主进程通信。不同的进程各自读取不同的文件,因此不应存在I/O问题。
这里有我尝试过的一切:
1.
pool = Pool(cpu_count())
j = 0
while j < procs:
pool.apply_async(run, args=())
sleep(0.2)
j += 1
pool.close()
-
j = 0
while j < procs:
processes.append(Process(target=run, args=()))
processes[-1].start()
sleep(0.2)
j += 1
-
pool = Pool(cpu_count())
j = 0
while j < procs:
pool.apply(run, args=())
sleep(0.2)
j += 1
pool.close()
提前感谢您的帮助
