使用subprocess调用Windows cmd.exe时并行进程限制失效问题

阿华AIGC实验室

2026-5-14

问题原因分析

这问题我之前也碰到过，核心还是对cmd.exe /c start的行为逻辑理解不到位：

当你用start命令启动程序时，默认情况下start会创建一个独立的新进程，然后立刻返回给cmd，这就导致你通过subprocess.Popen启动的cmd进程会瞬间执行完毕，p.wait()也就立刻结束。线程池看到当前任务完成，就会马上启动下一个cmd任务，最终所有cmd窗口同时弹出，所有目标程序也一起启动，完全没起到并发限制的作用。
而你之前直接调用mstsc.exe时没问题，是因为subprocess.Popen启动的就是mstsc进程本身，p.wait()会一直等待mstsc进程关闭才返回，线程池自然会按设定的并发数（比如2个）来依次启动后续任务。

解决办法

根据你的实际需求，我整理了两种可行方案：

方案1：直接调用目标程序（推荐，更高效）

如果不需要cmd和start的额外功能（比如工作目录、窗口标题其实可以通过subprocess的参数实现），直接用subprocess启动目标程序，既能避免不必要的cmd中转，又能保证并发限制生效。

示例代码：

import subprocess
from multiprocessing.pool import ThreadPool as Pool

def worker(cmd_args):
    # 用列表形式传递命令参数，避免字符串解析的坑，更安全可靠
    # 如需指定工作目录，直接通过cwd参数设置即可
    p = subprocess.Popen(cmd_args, cwd="E:\\pyworkspace\\FAST")
    p.wait()

# 直接定义目标程序和对应的参数列表
commands = [
    ['FAST_RV_W64.exe', '334.in'],
    ['FAST_RV_W64.exe', '893.in'],
    ['FAST_RV_W64.exe', '9527.in'],
    ['FAST_RV_W64.exe', '114514.in'],
    ['FAST_RV_W64.exe', '1919810.in']
]

# 限制同时运行的进程数为2
pool = Pool(processes=2)
results = [pool.apply_async(worker, [cmd]) for cmd in commands]
# 等待所有任务执行完成
ans = [res.get() for res in results]

如果需要类似start的新窗口功能，可以借助Windows API的标识实现：

import subprocess
import win32process

def worker(cmd_args):
    # CREATE_NEW_CONSOLE 会为进程创建新的控制台窗口
    p = subprocess.Popen(
        cmd_args,
        cwd="E:\\pyworkspace\\FAST",
        creationflags=win32process.CREATE_NEW_CONSOLE
    )
    p.wait()

方案2：让cmd等待start启动的进程结束（保留cmd/start场景）

如果你确实需要依赖start的特殊功能（比如必须通过cmd设置特定环境变量），可以给start加上/wait参数，强制cmd等待start启动的进程结束后再退出，这样subprocess.Popen的wait()就会等目标程序结束，线程池的并发限制就能正常工作。

示例代码：

import subprocess
from multiprocessing.pool import ThreadPool as Pool

def worker(cmd):
    # 字符串形式的cmd命令需要设置shell=True
    p = subprocess.Popen(cmd, shell=True)
    p.wait()

# 在start命令后添加/wait参数，让cmd等待目标进程完成
commands = [
    'cmd.exe /c start "Test1" /wait /d E:\\pyworkspace\\FAST\\ FAST_RV_W64.exe 334.in',
    'cmd.exe /c start "Test2" /wait /d E:\\pyworkspace\\FAST\\ FAST_RV_W64.exe 893.in',
    'cmd.exe /c start "Test3" /wait /d E:\\pyworkspace\\FAST\\ FAST_RV_W64.exe 9527.in',
    'cmd.exe /c start "Test4" /wait /d E:\\pyworkspace\\FAST\\ FAST_RV_W64.exe 114514.in',
    'cmd.exe /c start "Test5" /wait /d E:\\pyworkspace\\FAST\\ FAST_RV_W64.exe 1919810.in'
]

pool = Pool(processes=2)
results = [pool.apply_async(worker, [cmd]) for cmd in commands]
ans = [res.get() for res in results]

总结