僅用于個人學習記錄 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
同步或異步獲取返回值 #p = Pool()#p.map(funcname,iterable) 默認異步的執行任務,且自帶close,join功能#p.apply(), 同步調用進程池的方法#p.apply_async(),異步調用,和主進程完全異步,需要手動close和join
from multiprocessing import Pool
import time
def func(i): #