我有一個(gè)類，它有一個(gè)方法可以進(jìn)行一些并行計(jì)算，并且經(jīng)常被調(diào)用。因此，我希望我的池在類的構(gòu)造函數(shù)中初始化一次，而不是每次調(diào)用此方法時(shí)都創(chuàng)建一個(gè)新池。在此方法中，我想使用 apply_async() 為所有工作進(jìn)程啟動(dòng)一個(gè)任務(wù)，然后等待（阻塞）并聚合每個(gè)任務(wù)的結(jié)果。我的代碼如下所示：class Foo:     def __init__(self, ...):         # ...         self.pool = mp.Pool(mp.cpu_count())     def do_parallel_calculations(self, ...):         for _ in range(mp.cpu_count()):              self.pool.apply_async(calc_func, args=(...), callback=aggregate_result)                  # wait for results to be aggregated to a global var by the callback         self.pool.join()  # <-- ValueError: Pool is still running                  # do something with the aggregated result of all worker processes但是，當(dāng)我運(yùn)行此命令時(shí)，我在 self.pool.join() 中收到錯(cuò)誤消息：“ValueError：池仍在運(yùn)行”?，F(xiàn)在，在所有示例中，我都看到 self.pool.close() 在 self.pool.join() 之前被調(diào)用，我認(rèn)為這就是我收到此錯(cuò)誤的原因，但我不想關(guān)閉我的池，因?yàn)槲蚁胍谀抢锵麓握{(diào)用此方法時(shí)！我不能不使用 self.pool.join()，因?yàn)槲倚枰环N方法來等待所有進(jìn)程完成，并且我不想浪費(fèi)地手動(dòng)旋轉(zhuǎn)，例如使用“while not global_flag: pass”。我可以做什么來實(shí)現(xiàn)我想要做的事情？為什么多重處理不允許我加入仍然開放的池？這似乎是一件完全合理的事情。