我有一個類，它有一個方法可以進行一些并行計算，并且經常被調用。因此，我希望我的池在類的構造函數中初始化一次，而不是每次調用此方法時都創建一個新池。在此方法中，我想使用 apply_async() 為所有工作進程啟動一個任務，然后等待（阻塞）并聚合每個任務的結果。我的代碼如下所示：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但是，當我運行此命令時，我在 self.pool.join() 中收到錯誤消息：“ValueError：池仍在運行”?，F在，在所有示例中，我都看到 self.pool.close() 在 self.pool.join() 之前被調用，我認為這就是我收到此錯誤的原因，但我不想關閉我的池，因為我想要它在那里下次調用此方法時！我不能不使用 self.pool.join()，因為我需要一種方法來等待所有進程完成，并且我不想浪費地手動旋轉，例如使用“while not global_flag: pass”。我可以做什么來實現我想要做的事情？為什么多重處理不允許我加入仍然開放的池？這似乎是一件完全合理的事情。