У меня проблема при использовании пула Pathos.multiprocessing в Python3.
Я выполняю следующий код:
import pathos.pools as pp
pool = pp.ProcessPool()
num_serie = range(len(y))
pool.map(computeCharacteristics, num_serie)
pool.close()
pool.join()
pool.clear()
computeCharacteristics вычисляет ряд статистических данных с учетом временной ряд, а num_ser ie - индекс временного ряда в наборе данных.
В моем основном у меня есть несколько наборов данных, и у меня есть для l oop, включая все эти наборы данных. Предыдущий код работает для первых двух наборов данных, однако для третьего набора данных он останавливается и спит навсегда, хотя программа все еще продолжается.
Это происходит независимо от набора данных, используемого на третьем месте.
Заранее спасибо!