Параллельный в Python 2
У меня есть функция pre_raw()
и панды данные train_raw.values
в python3 я мог бы так:
with concurrent.futures.ThreadPoolExecutor() as executor:
executor.map(pre_raw, train_raw.values)
Как написать это на Python2?
Благодарю.
1 ответ
Решение
procs=[]
for val in train_raw.values:
p = multiprocessing.Process(target=pre_raw, args=(val,))
procs.append(p)
p.start()
for p in procs:
p.join()