【发布时间】:2020-07-03 09:17:43
【问题描述】:
我无法组织我的脚本以使用多处理。似乎产生了进程,但它一次又一次地执行整个脚本。在这个例子中,它会不断地print("PREPARATION")。
我认为我的问题在于脚本的组织。
import subprocess as sp
import multiprocessing
def func1():
blah
blah
blah
def func2():
blah
blah
blah
def derev_work(cmd):
proc = sp.run(cmd)
print(proc.stdout)
def main():
print("PREPARATION")
cmd_list = [[path_to_exe, arg1, arg2, arg3] for sheet in sortedsheets]
if __name__=="__main__":
print (multiprocessing.cpu_count())
pool = multiprocessing.Pool(multiprocessing.cpu_count())
results = []
r = pool.map_async(derev_work, cmd_list , callback=results.append)
r.wait()
print(results)
print("COMPLETION")
main()
【问题讨论】:
标签: python multiprocessing subprocess