在视觉相关类项目中，python作为能够快速进行AI项目开发的重要语言工具，配合深度学习架构，可高效完成任务。在封装给前端使用过程中，需要用C++来配合完成启动调用。下面介绍基本知识和过程，欢迎关注！一、 基本架构
把 Python 当成一个 "可执行的小函数库"，C++ 用 CreateProcess 把它当子进程拉起来。两边用 管道（pipe） 当电话线，一条线下行、一条线上行，每条消息就是一行 JSON。
一句话：C++ 父进程 ↔ 3 路 pipe ↔ Python 子进程。下行命令走 stdin，上行事件走 stdout，闲聊日志走 stderr。
C++ 端句柄 | 流向 | 内容 | Python 端 | 调用方式 |
m_stdinWrite | → | JSON 命令 | sys.stdin.read() | C++ WriteFile 写 / Python sys.stdin 读 |
m_stdoutRead | ← | JSON 事件 | sys.stdout | Python print(..., flush=True) / C++ 拆行 + JSON.parse |
m_stderrRead | ← | 人类日志 | sys.stderr | Python print(..., file=sys.stderr, flush=True) / C++ 原样透传 |
比喻：
- C++ 是前台，Python 是后台业务员
- 前台把客户的单子（JSON）从 stdin 窗口递给业务员
- 业务员每做完一步，从 stdout 窗口递出一张小票（JSON）
- 业务员的闲聊（stderr）单独从另一个窗口出来，给运维看
关键约束：stdout 是协议通道，任何 print 到 stdout 的非 JSON 内容都会污染协议（Python 的 print 默认走 stdout！）。
二、最小demo最小 demo（30 行 C++ + 20 行 Python）
Python 端 echo.py
# echo.py - 读 stdin 一行 JSON,回写一行 JSON 到 stdoutimport sys, jsoncfg = json.loads(sys.stdin.read())print(json.dumps({"echo": cfg, "pid": __import__("os").getpid()}), flush=True)
// launcher.cpp - 启动 python echo.py,写 JSON,读回 JSON#include#includeint main() {// 1. 建 2 路 pipe (stdin 下行 / stdout 上行)HANDLE inR, inW, outR, outW;SECURITY_ATTRIBUTES sa = { sizeof(sa), NULL, TRUE };CreatePipe(&inR, &inW, &sa, 0); // C++ 写 inW,Python 读 inRCreatePipe(&outR, &outW, &sa, 0); // Python 写 outW,C++ 读 outR// 2. 启动子进程STARTUPINFO si = { sizeof(si) };si.dwFlags = STARTF_USESTDHANDLES;si.hStdInput = inR; si.hStdOutput = outW; si.hStdError = outW;PROCESS_INFORMATION pi = {};std::string cmd = "python.exe echo.py";CreateProcessA(NULL, cmd.data(), NULL, NULL, TRUE, 0, NULL, NULL, &si, &pi);CloseHandle(inR); CloseHandle(outW); // 父进程关另一端// 3. 写 JSON 到 stdinconst char* json = R"({"hello":"world"})";WriteFile(inW, json, (DWORD)strlen(json), NULL, NULL);CloseHandle(inW); // 关 stdin,子进程 sys.stdin.read() 返回 EOF// 4. 读 stdout 一行char buf[4096]; DWORD n;ReadFile(outR, buf, sizeof(buf)-1, &n, NULL);buf[n] = 0;printf("recv: %s\n", buf);// 5. 收尸WaitForSingleObject(pi.hProcess, INFINITE);CloseHandle(pi.hProcess); CloseHandle(pi.hThread);CloseHandle(outR);}
编译跑通
cl launcher.cpp /EHsclauncher.exe# 期望:recv: {"echo": {"hello": "world"}, "pid": 12345}
注意：实际项目里 stdout 要拆行（一次 ReadFile 可能拿到半行或多行），但最小 demo 一发一收就一行，能跑通即可。
三、实战：D:\su_workspace\yolov11_cls_train1
项目一句话
WPF UI（C#）点"开始训练" → C++ DLL 创建 Python 子进程 → Python 用 ultralytics 训练 YOLO11 分类模型 → 每 epoch 通过 stdout 发回 top1/top5/loss → UI 显示。
三层架构
层级 | 模块 | 进程 | 语言 / 技术栈 | 通信接口 | 数据格式 |
L1 | cs_test.exe | 主进程 | C# WPF / .NET 4.8 | P/Invoke ycls_start(...) | JSON config |
L2 | yolo11_cls_DLL.dll | 同进程 DLL | C++ Win32 | CreateProcessW + pipe | JSON 命令写入 stdin |
L3 | python.exe + yolo11_train_runner.py | 子进程 | Python 3.9 / ultralytics | pipe stdio | emit_event("epoch", {...}) → stdout |
L4 | RTX 3060 (sm_86) | GPU | CUDA | — | tensor |
C++ 端关键代码（cpp_dll/yolo11_cls_Runner.cpp）
3 路 pipe 创建：
CreatePipe(&outR, &outW, &sa, 0); // stdoutCreatePipe(&errR, &errW, &sa, 0); // stderrCreatePipe(&inR, &inW, &sa, 0); // stdinsi.hStdInput = inR; // 子进程读这个si.hStdOutput = outW; // 子进程写这个si.hStdError = errW;CreateProcessW(NULL, cmdLine, ..., &si, &pi);// 父进程只保留: inW(写), outR(读), errR(读), pi.hProcess(等退出)// 另一端 inR / outW / errW 必须 CloseHandle,否则句柄泄漏,Python 端卡死CloseHandle(inR); CloseHandle(outW); CloseHandle(errW);
reader 线程 + 行缓冲拆帧（避免粘包/半包）：
// 单独线程死循环 ReadFile,丢进 LineBuffer 切 \n,再回调给 C# UIvoidLineBuffer::append(constchar* bytes, size_t len, vector& outLines) {data.append(bytes, len);while ((pos = data.find('\n')) != npos) {string line = data.substr(0, pos);if (line.back() == '\r') line.pop_back(); // 去掉 Windows \r\n 的 \routLines.push_back(std::move(line));data.erase(0, pos + 1); }}
写完配置立刻 CloseHandle stdin：
WriteFile(m_stdinWrite, configJson, len, &written, NULL);CloseHandle(m_stdinWrite); // ★ 关 stdin 触发 Python sys.stdin.read() 返回 EOFm_stdinWrite = nullptr;
Python 端关键代码（python_scripts/train_runner.py）
stdin 读配置：
# 关键:强制 UTF-8,避免 Windows 默认 GBK 编码出错for s in ("stdin", "stdout", "stderr"):getattr(sys, s).reconfigure(encoding="utf-8", errors="replace")config_str = sys.stdin.read() # 阻塞,等 C++ 写完 + 关 stdinconfig = json.loads(config_str)ok = train_model(config)
emit JSON 事件（flush=True 是关键）：
# 自家封装,本质就是 print(json.dumps(...), flush=True)def emit_event(type_: str, **kwargs):line = json.dumps({"type": type_, **kwargs}, ensure_ascii=False)print(line, flush=True) # ★ flush=True 必加,否则 C++ 永远收不到
ultralytics 回调里 emit（每 epoch 完事一条）：
def _on_fit_epoch_end(trainer):emit_event("epoch",epoch=trainer.epoch + 1,epochs=trainer.epochs,train_loss=float(trainer.tloss.mean()),top1=trainer.metrics["metrics/accuracy_top1"] * 100,top5=trainer.metrics["metrics/accuracy_top5"] * 100,lr=trainer.optimizer.param_groups[0]["lr"], )
一条 JSON 走全程（点 "Start" → 训练完 1 个 epoch）
1. C# UI 调用 ycls_start(handle, "train", configJson, cb, null)2. C++ DLL: - CreateProcessW(python.exe yolo11_train_runner.py) - WriteFile(inW, configJson) → CloseHandle(inW)3. Python: - sys.stdin.read() 返回 configJson - ultralytics.YOLO(model).train(data=..., epochs=10) - 第 1 epoch 完,on_fit_epoch_end 触发 - emit_event → print('{"type":"epoch",...}', flush=True)4. C++ DLL: - reader 线程 ReadFile 拿到一段字节 - LineBuffer 按 \n 切,拿到完整一行 JSON - 回调 C# UI (Yolo11ClsAPI.YclsLogCallback)5. C# UI: - Dispatcher.BeginInvoke 切到 UI 线程 - Logger.Append(s) → RichTextBox 显示 - UpdateProgressFromJson 解析 type=epoch,更新进度条
往返一次延迟：~5ms（pipe 缓冲 + ReadFile）。
