小编kum*_*aji的帖子

python ProcessPoolExecutor 在函数中不起作用

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)

没有警告或错误,但很长时间没有任何反应。

python multiprocessing

1
推荐指数
1
解决办法
1992
查看次数

标签 统计

multiprocessing ×1

python ×1