僅用于個人學習記錄 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
1 from multiprocessing import Pool,Queue。其中Queue在Pool中不起作用,具體原因未明。解決方案:進程池和線程池?如果要用Pool創建進程,就需要使用multiprocessing.Manager()中的Queue,與multiprocessing中的Queue不同q=Manager().Queue()#