◎欢迎参与讨论，请在这里发表您的看法、交流您的观点。
如何在进程池中让子进程创建新的子进程？
ID:20697 / 打印
进程池中创建子进程的难题
当有多个任务需要并行执行时，进程池无疑是一个强大的工具。然而，有时我们可能希望子进程本身创建更多的子进程。这个看似简单的要求在进程池中却带来了挑战，因为默认情况下，进程池中的子进程无法创建新的子进程。
解决方法：使用定制的manager
为了解决这个问题，我们可以创建一个定制的manager类，该类将允许子进程创建其他子进程。具体实现如下：
import multiprocessing import os class CustomManager(multiprocessing.Manager): def __init__(self): super().__init__() self.lock = self.Lock() self.process_count = 0 def create_process(self, target, args=(), kwargs={}): self.lock.acquire() # 记录当前已创建的子进程数 self.process_count += 1 # 创建子进程 p = self.Process(target=target, args=args, kwargs=kwargs) p.start() # 释放锁 self.lock.release() return p if __name__ == '__main__': # 创建定制的Manager manager = CustomManager() # 将定制的Manager传递给进程池 pool = multiprocessing.Pool(processes=10, manager=manager) # 在子进程中创建新的子进程 def create_new_process(msg): # 获取定制的Manager manager = multiprocessing.current_process().manager # 创建新子进程 p = manager.create_process(os.system, args=("echo {}".format(msg),)) # 等待新子进程结束 p.join() # 将任务添加到进程池 for i in range(20): pool.apply_async(func=create_new_process, args=(str(i),)) # 关闭进程池 pool.close() pool.join() # 输出创建子进程的总数 print('Total sub-processes created:', manager.process_count)通过使用定制的manager，我们可以在进程池中创建子进程，并使子进程能够创建自己的子进程。这为处理复杂的工作负载提供了更大的灵活性。
