如何在Python多进程中通过循环调用多个函数

你可以把所有需要执行的函数整理到一个列表中，通过循环批量提交任务到进程池，再统一获取结果，具体实现如下：

完整代码示例 #

from multiprocessing import Pool

def func1():
    return "结果来自func1"

def func2():
    return "结果来自func2"

def func3():
    return "结果来自func3"

def func4():
    return "结果来自func4"

if __name__ == '__main__':
    # 1. 把所有要并行执行的函数放到列表中
    target_funcs = [func1, func2, func3, func4]
    
    with Pool(processes=2) as pool:
        # 2. 循环提交任务，保存每个任务的结果对象
        results = []
        for func in target_funcs:
            res = pool.apply_async(func, ())
            results.append(res)
        
        # 3. 循环获取每个任务的返回值
        outputs = []
        for res_obj in results:
            # 保留原有的timeout设置
            output = res_obj.get(timeout=20)
            outputs.append(output)
        
        # 查看所有结果
        for idx, out in enumerate(outputs):
            print(f"func{idx+1}的执行结果: {out}")

关键说明 #

• 核心是将函数存入列表：后续新增funcN时，只需把函数添加到target_funcs列表，无需修改循环逻辑
• 进程池的processes参数可根据CPU核心数或实际需求调整，比如用os.cpu_count()自动匹配核心数
• 如果函数需要传参，只需在apply_async的第二个参数传入对应元组即可，例如pool.apply_async(func, (arg1, arg2))

内容的提问来源于stack exchange，提问作者Nic