python 獲取進程，python進程池并行處理

僅用于個人學習記錄

import multiprocessing as mp
num_cpus=mp.cpu_count()#獲取機器CPU個數
pool=mp.Pool(num_cpus)
results=[]   #儲存結果
for idx in train_ids:#異步處理,pool.apply_async第一個參數是要運行的函數result=pool.apply_async(process_text,args=(ids,split_method,'train'))results.append(result)
for idx in test_ids:result=pool.apply_async(process_text,args=(ids,split_method,'test'))results.append(result)
pool.close()  #關掉線程池
pool.join()