Впервые я использую пакет Multiprocessing.Я хочу вычислить функцию ML несколько раз (с другим вводом).
Я пробовал следующее, где серия - это итерация, а 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выход).После ожидания «долгого» времени кажется, что программа работает бесконечно и никогда не возвращает результат.
Может кто-нибудь объяснить мне, почему и как вы это исправите?