pyhton ProcessPoolExecutor 在公共行中工作,但在添加到函数后不运行
它是这样工作的
from concurrent import futures
def multi_process(func, paras, threads):
with futures.ProcessPoolExecutor(max_workers=threads) as pool:
res = pool.map(func, paras, chunksize=threads)
return list(res)
p = multi_process(func,paras,threads)
Run Code Online (Sandbox Code Playgroud)
但根本不工作,如下所示
def upper(paras,threads):
def func:
some func
def multi_process(func, paras, threads):
with futures.ProcessPoolExecutor(max_workers=threads) as pool:
res = pool.map(func, paras, chunksize=threads)
return list(res)
p = multi_process(func,paras,threads)
return p
p = upper(paras,threads)
Run Code Online (Sandbox Code Playgroud)
没有警告或错误,但很长时间没有任何反应。