Я знаю, что могу получить результат последовательно, набрав multiprocessing
, но теперь я хочу знать, могу ли я получить результат последовательно, набрав threading.Thread
. Я ожидаю, что такой код будет реализован threading
.
import multiprocessing as mp
import multiprocessing.pool
pool = mp.Pool(processes=mp.cpu_count() - 1)
# arguments
import numpy as np
train = np.random.randint(100,size=(100000,2))
args = zip([train for _ in range(10))],
[i for i in range(10))])
woe_res = dict(zip([col_idx for col_idx in range(10)], pool.starmap(myfunction, args)))
pool.close()
pool.terminate()
pool.join()