python 多进程存储返回值import warningsimport timefrom multiprocessing import Managerfrom multiprocessing.dummy import freeze_supportimport pandas as pdfrom multiprocessing.pool import Pooldef get_pool(tu): text = "djaiojeiwoiobnaeoijojxocvmoiojes" * 10000 text_df = pd.DataFrame({"voc_b_id": list(text), "count": [1] * len(text)}) tu.append(text_df.groupby("voc_b_id", as_index=False)["count"].count())if __name__ == '__main__': freeze_support() warnings.filterwarnings('ignore') manager = Manager() return_list = manager.list() pool=Pool(8) start=time.time() for i in range(200): pool.apply_async(get_pool,args=(return_list,)) pool.close() pool.join() print(time.time()-start) pd.concat(list(return_list)).groupby("voc_b_id", as_index=False)["count"].count()