多处理。池未编译

Question

我第一次使用多处理软件包。我想多次计算一个ML函数（使用不同的输入）

我尝试了以下方法，其中series是iterable，fbp_prediction是一个返回列表的函数：

import multiprocessing as mp
from tqdm import tqdm

p = mp.Pool(mp.cpu_count())
predictions = list(tqdm(p.imap(fbp_prediction, series), total=len(series)))
p.close()
p.join()
print("--- %s seconds ---" % (time.time() - start_time))

运行时，进程似乎保持在0%（tqdm输出）。在等待“长”时间后，程序似乎无限期地运行，并且永远不会返回输出

有谁能解释一下你为什么要修理它，以及如何修理它