并发于 Python 2

Question

我在 python3 中有一个函数 pre_raw() 和 pandas 数据 train_raw.values 我可以这样：

with concurrent.futures.ThreadPoolExecutor() as executor:
     executor.map(pre_raw, train_raw.values)

如何写在Python2上？

谢谢。

Answer 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()

并发于 Python 2

Concurrent in Python 2

concurrency

multiprocessing