Python多进程：带多参数函数指定核心数执行的问题

错误原因分析 #

你写的pool.map(funct(3, 44))犯了两个关键错误：

• 直接调用了funct(3,44)，传入的是函数执行后的返回值，而非函数本身
• map()方法要求第二个参数是可迭代对象（比如列表、元组），你完全未传入该参数，因此触发TypeError

正确解决方案 #

方法1：用Pool.starmap()处理多参数任务 #

如果需要批量执行带多参数的函数，把每组参数打包成元组存入列表，starmap()会自动解析元组内的参数传递给函数：

from multiprocessing import Pool

def funct(a, b):
    # 执行你的bat文件逻辑，比如用subprocess调用
    print(f"执行参数：a={a}, b={b}")

if __name__ == '__main__':
    cores = int(input("输入核心数："))
    pool = Pool(processes=cores)
    # 准备多组参数，示例仅一组，可扩展为[(3,44), (5,66), ...]
    params_list = [(3, 44)]
    pool.starmap(funct, params_list)
    pool.close()
    pool.join()

方法2：用functools.partial固定部分参数 #

如果仅部分参数需要动态传递，可将多参数函数转为单参数函数适配map()：

from multiprocessing import Pool
from functools import partial

def funct(a, b):
    print(f"执行参数：a={a}, b={b}")

if __name__ == '__main__':
    cores = int(input("输入核心数："))
    pool = Pool(processes=cores)
    # 固定b参数为44，生成仅需传入a的新函数
    partial_funct = partial(funct, b=44)
    # 用map传递a的可迭代列表
    pool.map(partial_funct, [3])
    pool.close()
    pool.join()

关于Process的说明 #

Process是创建单个进程的API，无法直接控制同时运行的进程数（即核心数）。而Pool的processes参数正是用来指定并行进程数量的，完全匹配你指定X核运行的需求。

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