Python asyncio创建协程列表并gather批量执行subprocess子进程是否可行？

你提供的实现方案是可行的，完全可以满足你提出的两个功能需求。

可行性验证 #

• 你通过遍历tasks_to_do任务数组，为每个Task对象实例化对应create_task协程并存入tasks_to_run列表的逻辑，已经实现了基于不同任务数组填充协程列表的需求。
• 你调用await asyncio.gather(*tasks_to_run)的逻辑会自动并发调度所有协程执行，直到所有子进程任务全部运行完成后才会继续执行后续打印结果的代码，也满足了运行所有协程并等待全部执行完成的需求。

可选优化点 #

• 目前create_task协程没有显式设置返回值，asyncio.gather最终返回的列表L中所有元素都会是None，如果你需要收集每个任务的执行结果，可以在create_task末尾返回类似{"return_code": proc.returncode, "stdout": stdout, "stderr": stderr}的结构化数据即可。
• 可以给asyncio.gather添加return_exceptions=True参数，避免单个子进程执行报错时直接终止其他仍在运行的任务，报错信息会作为对应位置的返回值存入L，后续可以统一批量处理异常。
• asyncio.create_subprocess_shell依赖系统shell解析执行命令，如果task.code包含不可信的外部输入会存在shell注入风险；如果命令来源不可控，建议改用asyncio.create_subprocess_exec拆分命令名和参数执行，规避注入风险。

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