人工智能AI Agent代码智能体Agent 编排CLIAI 应用【免费下载链接】gsd-2A powerful meta-prompting, context engineering and spec-driven development system that enables agents to work for long periods of time autonomously without losing track of the big picture项目地址https://gitcode.com/gh_mirrors/gs/gsd-2点击查看免费下载Pigsd-2 仓库中的 coding agent并不要求你在 Agent 完成一轮思考后才输入下一条指令。借助内置的消息队列Message Queue你可以在 Agent 流式输出过程中随时排队发送消息让指挥与执行并行推进。本文以 docs/dev/what-is-pi/12-the-message-queue-talking-while-pi-thinks.md 为核心结合仓库源码packages/pi-coding-agent、packages/pi-agent-core中的真实实现完整讲解队列的两类消息steering / follow-up、四个按键的精确行为、两种投递模式的配置以及底层 Agent 循环如何处理这些排队消息。为什么需要消息队列不让等待打断指挥节奏传统的 Agent 交互模型是提问 → 等待完成 → 再提问的串行模式。当 Agent 正在执行一连串工具调用比如先搜索、再读文件、再改代码时用户只能干等如果中途发现方向错了也只能等整轮结束后再纠正白白消耗 token 与时间。Pi 的消息队列打破了这一限制你不需要等待 Agent 完成即可继续输入指令输入内容先进入队列暂存队列根据消息类型在恰当的时机注入给 Agent已排队但尚未投递的消息可以随时撤回重新编辑。这套机制在 packages/pi-coding-agent/src/core/agent-session.ts 中有完整实现——会话对象内部用两个数组分别跟踪待投递消息_steeringMessages与_followUpMessages见该文件第 251-254 行并通过prompt()的streamingBehavior选项决定排队方式第 192-193 行。四键操控排队、发送、中止与取回原文档给出了一张精炼的按键速查表以下逐一展开并结合源码说明每个按键背后触发的动作。按键行为底层动作源码佐证Enter排队一条steering引导消息——在当前工具结束后投递并跳过剩余的后续工具调用触发prompt(..., { streamingBehavior: steer })AltEnter排队一条follow-up跟进消息——在 Agent 完成全部工作后投递绑定到followUpaction调用session.followUp()Escape中止 Agent并把队列中的消息恢复到编辑器绑定到interruptaction配合clearQueue()恢复文本AltUp把排队中的消息取回编辑器重新编辑后再次发送绑定到dequeueaction调用handleDequeue()在源码层面这四个按键由按键绑定管理器统一定义packages/pi-coding-agent/src/core/keybindings.ts 中声明了followUp: altenter与dequeue: altup第 66-67 行interrupt: escape第 54 行并归类为AppAction枚举中的followUp、dequeue第 30-31 行。按键并不是写死的用户可以通过~/.pi/keybindings.json之类的配置文件覆盖这些默认值KeybindingsManager.loadFromFile会在存在配置文件时加载并覆盖默认映射第 151-158 行。交互界面侧packages/pi-coding-agent/src/modes/interactive/interactive-mode.ts 中通过this.defaultEditor.onAction(followUp, ...)与onAction(dequeue, ...)把按键动作接到具体处理函数上第 2173-2174 行当队列非空时界面会在输入区下方给出提示↳ AltUp to edit all queued messages第 3124-3129 行提醒你可以随时取回编辑。Steering引导消息中途改道的利器Steering用于过程纠偏停一下改成这样做。这条消息会在当前工具执行完后投递但 LLM 本轮响应中剩余的后续工具调用会被跳过。典型场景Agent 正在读文件准备改代码你发现方案不对按Enter输入Stop, do this instead当前正在执行的那个工具调用会正常收尾拿到结果但其后排队的所有工具调用全部作废steering 消息立即成为下一轮 LLM 输入Agent 按新指示重新规划。底层实现位于 Agent 主循环 packages/pi-agent-core/src/agent-loop.ts。在工具执行阶段循环会通过config.getSteeringMessages()主动拉取待投递的 steering 消息第 569-571 行并将它们作为工具执行结束后的待处理消息返回steeringMessages字段第 504 行随后外层循环把这些消息作为新的pendingMessages注入下一轮推理第 377-379 行。也就是说steering 消息被投递的时机严格锚定在当前工具结束与下一轮 LLM 推理开始之间——这正是跳过剩余工具调用的实现原理。在会话层prompt()方法在 Agent 正在流式处理时若传入streamingBehavior: steer则会调用内部方法_queueSteer()把消息追加进_steeringMessagesagent-session.ts 第 1441-1442 行如果省略streamingBehavior而 Agent 正在忙碌会话会明确报错提示你必须指定steer或followUp之一第 1167-1171 行——这保证了排队行为永远是显式、可预期的。Follow-up跟进消息任务链式接力Follow-up用于任务串联等你做完那个顺便再做这个。这条消息会一直等到 Agent 不再有任何工具调用时才投递。典型场景你让 Agent 先重构一个函数同时按AltEnter排入完成后顺手更新对应的测试文件Agent 会先完整执行第一轮任务含所有工具调用全部收尾后才收到 follow-up 消息开始第二轮工作与 steering 不同follow-up 不会打断当前工作流适合下达附加任务而非纠偏指令。实现层面agent-loop.ts 在主循环检测到工具调用全部结束turn完成之后才会通过config.getFollowUpMessages?.()读取 follow-up 消息并纳入下一轮pendingMessages第 386-389 行而会话层对应的投递路径是agent.followUp(appMessage)agent-session.ts 第 1520-1521 行与_queueFollowUp()第 1460-1461 行。两种投递模式one-at-a-time 与 all原文档给出的两条设置项是控制一次投递多少条排队消息的关键旋钮设置项取值含义steeringModeone-at-a-time默认/all每条 steering 消息依次单独投递还是把所有排队的 steering 消息一次性全部投递followUpMode同上对 follow-up 消息队列的同样控制默认值one-at-a-time意味着如果你连续排队了 3 条 steering 消息Agent 每完成一轮处理就只接收 1 条先按第一条纠偏、再接收第二条、再接收第三条——每次改道之间都给 Agent 一次重新规划的机会。而all模式则把当前队列里的消息一次性合并进同一轮输入适合一次把所有要求说清的场景。源码确认在 packages/pi-coding-agent/src/core/settings-manager.ts 中这两个设置被声明为可选字段steeringMode?: all | one-at-a-time与followUpMode?: all | one-at-a-time第 183-184 行读取时若未配置则回落到默认值one-at-a-time第 767、775 行。该文件还提供了从旧字段queueMode到steeringMode的自动迁移逻辑第 458-460 行说明这是经过演进的成熟特性。会话层通过steeringMode/followUpMode两个 getter 把当前模式暴露给 UIagent-session.ts 第 972-980 行交互界面据此在状态栏或设置选择器中展示当前模式。Escape 与 AltUp安全的后悔药队列机制提供了两条反悔通道保证误操作可恢复Escape中止 恢复按 Escape 会触发interruptaction 中止正在运行的 Agent同时把队列中尚未投递的 steering / follow-up 消息全部恢复到输入编辑器让你能直接修改或撤销它们。会话层对应clearQueue()方法它会清空队列并返回{ steering, followUp }两个数组agent-session.ts 第 1585-1609 行交互层再把这些文本回填进编辑器interactive-mode.ts 第 3100-3136 行的clearAllQueues()与取回逻辑。AltUp仅取回如果只想修改排队内容、不想中止 Agent按 AltUp 触发的dequeueaction 会把队列消息取回编辑器编辑后可重新排队或直接发送。这两条路径共同保障了排队 ≠ 无法撤回——你在等待期间随手排入的想法随时可以收回或改写。一条消息的完整生命周期从按键到 Agent 循环综合上述源码可以把一条排队消息的完整旅程串起来按键触发用户在交互编辑器中按下 Enter / AltEnter经 keybindings.ts 解析为对应 action会话排队interactive-mode.ts 的处理器调用session.prompt(text, { streamingBehavior })或直接调用session.steer()/session.followUp()消息被 push 进_steeringMessages/_followUpMessagesUI 反馈会话状态变化事件被发出输入区下方出现排队提示↳ AltUp to edit all queued messagesAgent 循环消费agent-loop.ts 在恰当的时机当前工具结束后 / 整轮工作结束后通过getSteeringMessages()/getFollowUpMessages()拉取消息注入下一轮 LLM 推理消息去重移除当消息被投递、Agent 开始处理用户消息时会话会把已投递文本从对应队列数组中移除agent-session.ts 第 438-446 行保证队列不会重复投递。这条链路在 packages/pi-coding-agent/src/modes/interactive/controllers/input-controller.test.ts 与 packages/pi-coding-agent/src/modes/interactive/components/interactive-key-handling.test.ts 等测试中有覆盖验证了按键与排队行为的契约。最佳实践小结方向未定时用 Follow-up附加任务、链式要求、后续检查类指令全部用 AltEnter 排队不干扰当前工作流发现跑偏时用 Steering当前工具结束后立即纠正但要意识到剩余工具调用会被跳过避免把纠偏用在只需等待的场合批量指令用all模式如果一次想给 Agent 完整的新一轮要求把steeringMode/followUpMode切到all可合并投递、减少轮次与 token 消耗不确定就取回重发排队后想法有变AltUp 取回编辑Escape 则连 Agent 一起中止——不要带着旧指令继续跑。消息队列让 Pi 的交互从串行问答升级为并行指挥是 docs/dev/what-is-pi/11-the-interactive-tui.md 所述交互界面的核心能力之一想深入了解 Pi 的完整架构与其余能力可继续阅读 docs/dev/what-is-pi/README.md 中的系列文档。赞分享人工智能AI Agent代码智能体Agent 编排CLIAI 应用【免费下载链接】gsd-2A powerful meta-prompting, context engineering and spec-driven development system that enables agents to work for long periods of time autonomously without losing track of the big picture项目地址https://gitcode.com/gh_mirrors/gs/gsd-2点击查看免费下载相关推荐免费开源的 TVBoxOSC3 步让老电视盒子流畅播放高清视频免费开源的 TVBoxOSC3 步让老电视盒子流畅播放高清视频 4K 电影拷进老电视盒子点开提示格式不支持。装上 TVBoxOSC 自动构建的开源电视盒子应TDengine消息队列(TMQ)开发实战指南TDengine消息队列 TMQ 开发实战指南 概述 TDengine消息队列TMQ是TDengine时序数据库提供的高性能、低延迟消息队列服务专为实时数数据库时序数据库大数据物联网云原生Warp LRC 自动排队Auto-queue机制解析Agent 驱动长任务期间的消息排队设计与实现Warp LRC 自动排队Auto queue机制解析Agent 驱动长任务期间的消息排队设计与实现 导读 当 Warp 中的 Agent 正在执行一条桌面应用开发者工具人工智能AI 应用AI Agent代码智能体上一篇For the Badge徽章生成器深度教程打造个性化开发者名片下一篇GoCity终极Go源代码3D可视化工具 - 代码城市新体验创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考