dsh-parallel-pool — 动态滚动窗口子代理任务池
把"整批独立任务"一次交给任务池,主对话始终不阻塞:提交后立即返回 job id,
后台滚动窗口补位(任何子代理一结束立刻派发下一任务,不等整轮);每个子任务
结算时立即把该任务结果投递给主对话,整批结束后再投递完整汇总与时间线。
用法(模型可见工具)
parallel_pool {
tasks: [{ prompt, description?, model? }, ...], // ≤64 个独立任务
maxConcurrency?: 2, // 默认 4,范围 1..16
provider?: 'spawn' | 'fork', // 默认 'spawn'(全新子代理)
failFast?: false, // 首个失败后停止补位
background?: true, // 兼容参数;始终非阻塞,返回 job id 并增量推送
}
- 始终非阻塞:无论
background 是否为 false,都立即返回
{kind:'background', jobId}(毫秒级),池在后台滚动调度;每个子任务结算
时立即向主对话投递该任务结果,主对话无需等待整批结束即可及时处理。
job_output 实时返回每任务进度与终态富文本(v0.3.0);job_kill
中止批任务并投递部分结果。
- 整批结束后仍会投递完整汇总(含每任务
startedAt/endedAt 时间线)。
- 返回汇总:
total/completed/failed/aborted/skipped、总耗时、峰值并发、
rollingRefill(是否发生补位)、每任务结果与时间线。
- 系统提示引导:对 2+ 独立任务整批交给 parallel_pool,而不是手动逐波派发
subagent(引导段 order 110,早于官方 tool-subagent 的 116.5)。
- 宽松校验(v0.3.0):
model/description 为空字符串视为未提供。
设计
- 工作器池(v0.4.0,性能优化):持久子代理数 = 并发数而非任务数——
每个 worker 串行处理任务(首任务随
startContinuable 创建派发,后续经
host queue / sendMessage 派发),每任务一回合、subagent/end 逐回合结算。
- DSH 0.1.2-rc.1 兼容(v0.8.0):适配官方子代理 API 变化——
followup
已替换为 host queue 符号回调(Symbol.for('dsh.subagent.queuePrompt'),
缺失时回退公开 sendMessage);interrupt 使用
{ kind: 'ancestor', agent: parent };listChildren 改为异步
listChildren(parent.id)。
- DSH 0.1.5-rc / 桌面版适配(v0.10.0):peer 范围按 semver 预发布元组规则
改写(
>=0.0.1-rc <2 不匹配 0.1.5-rc.2,会被官方 Electron 桌面版的
validateDesktopPluginGraph 直接拒绝);补齐直接 import 的第一方 peer
(@deepseek-ai/dsh-timeout、@deepseek-ai/schemastery);dsh.client 补上
实际依赖的 client 模块声明(ui-settings / ui-settings-plugins /
ui-primitives / api-remotes)。host 半只用 jobs/subagents/tools 服务,
不依赖 webserver,因此桌面版(默认禁用 webserver)下功能完整。
- 设置卡片样式自持(v0.10.1):卡片不再引用官方构建产物的 CSS Module 哈希类名
(
YyYd_a_card / At1oFq_field 等)。这类哈希随内核构建变化——同一版本在 web 版
与桌面版 runtime 里都不相同——一旦失配卡片就退化成裸文本。现改为自有类名
(dshpp-*)+ 自带样式(只依赖公开设计变量 --dsw-*),折叠箭头改自绘 SVG。
client 半因此除 cordis 服务(slots / settingsScope)外不依赖任何内核内部结构。
- owned job 化(v0.9.0):后台批任务以
owner: parent 注册,获得会话
隔离、per-owner 并发限制和 agent 生命周期清理;plugin 在 global 层先投递
完整汇总并把共享 snapshot 标记为 reported,抑制官方 tool-jobs 重复通知。
Web 会话回显与子代理目录的加载负载不再随任务数增长(实测:189 个子代理
→ listChildren 13.6s,每冷子代理折叠 ~68ms;64 任务批次旧引擎产生 64 个
子会话,新引擎仅 maxConcurrency 个)。
- 健壮性(v0.5.0):
taskTimeoutMs(默认 30min,0=不限):单任务超时 → interrupt 子代理 +
记 failed,防 worker 挂死导致整批永不结算;
maxRetries(默认 1,0..3):失败自动重试(换新子代理执行,
retryDelayMs 默认 5s),覆盖瞬态故障(配额抖动/网络);
tasksPerWorker(默认 12):每 worker 处理任务数上限,到点退役换新,
防长批下上下文累积污染;
- per-run 事件监听:只登记本池在途子代理的结算事件,随 run 注销零噪音。
- job readOutput(v0.3.0):每任务结算即更新进度文本(
N/M settled +
逐行结果),job_output 实时可见;终态输出完整汇总——模型自行轮询也能
拿到富文本结果,不再只有裸状态串。
- 后台 job 归属调用 agent:并行池任务以
owner: parent 注册,获得会话
隔离、per-owner 并发限制和 agent 生命周期清理;本插件 global 层
onJobDone 在官方 tool-jobs 之前投递完整汇总,并把共享 snapshot 标记为
reported,避免官方重复发“去 job_output”通知。
- 失败详情富化(v0.0.2):子代理失败(如模型路由 402 余额不足)时,经
subagent/end 事件定位子会话,回读 turn/end 底层错误并入结果 error 字段,
避免外部故障被误判为插件问题。
- 中止时停止派发并逐个
interrupt in-flight 子代理(1s 宽限期等待 worker
记录已结算结果),未启动任务标记 skipped。
- 所有注册挂
ctx.effect:卸载/热重载自动清理。
安装(npm / dsh plugin)
dsh plugin --profile web add @stars-w/dsh-parallel-pool
包已发布到 npm(public),安装后会自动追加到 profile 的
dsh.profile.bundles,作为标准 bundle 加载。
本仓库即 npm 发布的 @stars-w/dsh-parallel-pool,包名以 package.json 为准。
官方 Electron 桌面版:桌面版独占 desktop profile(CLI 不能启动/修改它),
请在桌面版应用内安装。本包已按桌面版契约打包:发布产物不含嵌套 node_modules、
dsh.bundle.patch 指向 cordis.patch.yml、第一方共享包只出现在 peerDependencies
(桌面版 autoInstallPeers: false + nodeLinker: hoisted,由宿主 junction 提供)。
桌面版默认不启用 webserver,本插件的 host 半与设置卡片均不依赖它。
Web 插件配置
在 Web 插件配置页中可设置:
maxConcurrency:默认 4,范围 1..16。关闭自动时按此固定并发运行;自动模式失败时回退到此值。
autoConcurrency:默认关闭。
- 关闭时:按
maxConcurrency 固定并发运行。
- 开启时:若调用未显式传
maxConcurrency,插件会调用大模型,根据当前
provider/model、任务数、活跃子代理/任务数、系统负载/内存/进程占用等
环境指标自动建议并发数。
- 自动模式没有额外的人为上限;仅在系统负载/内存/进程占用达到极端危险值时,
插件会硬性收紧到很低并发作为安全兜底。
- 自动模式失败或超时时回退到
maxConcurrency。
- 单次调用显式传
maxConcurrency 时始终优先于自动分配,保留手动控制能力。
修改后下一次调用 parallel_pool 即生效。
本地开发 / 构建 / 注入
bash scripts/build.sh # 依赖落地 + 语法/导入链校验
npm run check:desktop # 桌面版契约离线校验(npm pack 产物)
依赖落地策略(loader 内部解析器实测只认包根 index.js、不读 package.json):
dsh-tools 走 junction;dsh-llm 及其传递闭包(cordis/cosmokit/schemastery/
dsh-timeout)复制为真实目录副本并生成包根 index.js 再导出垫片。
该副本策略仅用于本地注入/调试:files 白名单已排除 node_modules,
npm 发布产物不含任何嵌套第一方包副本(桌面版校验会拒绝嵌套共享包副本)。
npm run check:desktop 会用官方桌面版的 validateDesktopPluginGraph
校验 pack 产物(默认 pack 当前目录,可用 --pack <tgz> 校验既有产物)。
本地注入器工具:dev_build_plugin → dev_inject_plugin →
dev_uninject_plugin(卸载)。