调度器

本页定义 Holon 调度器的当前契约：它消费哪些输入、如何推导调度姿态与可运行性、 以及发出哪些决策。页面同时记录附加的协议转换层：它把调度器决策包进带重放保护的 原子事务，并承担显式 activation 归属、终态结算和公开诊断事件流。

Last verified: 2026-09-13 against src/runtime/scheduler.rs, src/runtime/scheduler_executor.rs, src/runtime/waiting.rs, src/runtime/closure.rs, src/runtime/turn/execution.rs, src/runtime_db/transitions.rs, src/runtime_event.rs, and src/types.rs.

源 RFC

• 运行时调度器契约
• 调度器与 WorkItem 统一执行协议
• 调度器切换简化
• 调度器等待状态与可恢复的 Agent 延续
• 等待平面与重新激活
• 延续触发器
• 以 WorkItem 为中心的 Agent 运行时
• Agent 激活、结算与分发：历史性的激活/结算设计；在统一协议分配了当前权威之处已被取代

核心模型

调度器回答的问题是：给定 Agent 的当前状态，下一步该做什么？

它消费一个 SchedulerProjection，即由下列来源汇总而成的快照：

投影是只读快照；调度器从不直接修改持久状态。决策发出后交给执行器。

调度器输入（SchedulerInput）

调度器决策（SchedulerDecisionKind）

每个决策都携带元数据：reason、model_reentry、liveness_only、 work_item_id、task_id 和 evidence。

决策流程

                    SchedulerInput
                         │
                         ▼
              ┌─────────────────────┐
              │ Status == Stopped?  │──Yes──► Stop
              └─────────┬───────────┘
                        │ No
                        ▼
              ┌─────────────────────┐
              │ Turn in progress?   │──Yes──► Noop
              └─────────┬───────────┘
                        │ No
                        ▼
         ┌──────────────────────────┐
         │ Queue has pending input? │──Yes──► StartModelTurn
         └──────────────┬───────────┘        (or ReduceMessageOnly)
                        │ No
                        ▼
         ┌──────────────────────────┐
         │ Runnable WorkItem?       │──Yes──► EmitSystemTick
         └──────────────┬───────────┘        (ContinueActive)
                        │ No
                        ▼
         ┌──────────────────────────┐
         │ Active wait condition?   │──Yes──► WaitFor{Task,
         └──────────────┬───────────┘         External,Timer,Operator}
                        │ No
                        ▼
                      Sleep

WorkItem 调度状态

WorkItem 会经过调度器消费的这些调度状态：

唤醒/休眠边界

• Sleep 是轮次结束后的内部调度器决策。调度器据此决定 Agent 真正进入 Asleep，还是带着队列中的工作继续。
• WaitFor 记录显式等待状态，然后让出轮次。它是面向模型的任务、外部和操作者 等待路径。每次调用必须选择 delivery=final（等待前发布面向操作者的最终简报） 或 delivery=silent（直接结算等待，无需额外轮次）。等待注册、交付模式、轮次终态 与队列终态在单一事务中原子提交，且任务结果等待严格解析自任务创建时捕获的所有者。
• StayIdle 表示 Agent 已处于休眠，调度器无事可做；它与 Sleep（首次转换） 不同。
• EmitSystemTick 注入一条内部后续消息，让模型在空闲边界发现可运行 WorkItem 时重新进入。
• CompleteWorkItem 报告晋升结束轮次后，其余可运行的 WorkItem 由同一条工作队列 SystemTick 路径恢复。
• 唤醒提示是活性信号：它们让调度器重新评估，但本身不携带面向模型的内容。
• 重复抑制使用幂等键，避免对同一个唤醒提示或 continue-active 信号产生多余的 system tick。

协议转换层

调度器把每个边界都包进原子的 QueueTransitionCommand 事务，该事务可以同时：

1. 提交队列操作（admit、claim 或 enqueue）；
2. 更新 Agent 状态投影；
3. 持久化消息证据、transcript 条目和审计事件；
4. 绑定规范的 activation 归属方和执行处置；
5. 持久化结算、恢复和投递证据。

所有效果在同一个 SQLite 事务中提交。事务失败或 CAS 不匹配时，不会留下任何部分的 队列、activation、结算或投递状态。

规范调度器是唯一的运行时引擎。队列、WorkItem、等待、任务、Turn、transcript、 brief、投递、activation、结算和执行事实共享同一权威和事务路径。

已接受的转换契约退役了运行时 manifest/preflight 门、逐场景权威、自动硬阻塞回滚、 生产影子比较、遗留引擎和运行时引擎选择器。历史选择器配置不再是运行时输入。

集成点

QueueTransitionCommand 在每个调度器边界提交。每个边界都记录下一个边界所需的 规范事实：

语义决策平面不属于生产准入。它的生产模块和 fixture 已被移除。确定性的结构绑定和 规范协议保留了全部状态转换控制。

公开诊断事件流

调度器为每个经过 append_scheduler_decision 的决策发出一个类型化的 SchedulerDiagnosticAuditEvent。该事件携带：

事件通过 RuntimeEventKind::SchedulerDiagnostic 发出，与遗留的 scheduler_decision 审计事件并列。两者与调度器决策在同一事务中持久化。 类型化事件是公开的可观测面；遗留审计事件保留用于向后兼容。

调度建议

SchedulingAdvisory 是内部的、非权威的告警系统，用于发现潜在的调度器状态不一致： 空闲姿态下存在可运行工作、外部等待恢复能力薄弱、不可恢复的阻塞 WorkItem 等。 建议以 scheduling_advisory 审计事件追加，并与近期事件去重。

建议不是诊断事件流意义上的诊断。它们是供调试和运维感知使用的内部提示； 确定性的调度器投影和姿态推导仍是调度决策的唯一权威。

已知缺口

• SchedulerDecisionKind 的变体有意多于粗粒度的 RFC 姿态标签。RFC 姿态是稳定的 轮次结束词汇；决策变体是具体的运行时动作和重复抑制结果。
• 调度器发布验收在运行时权威路径之外验证原子性、重启、有界并发负载、故障处理和 FIFO WorkItem 投影。它既不是校准过的生产 SLO，也不能替代针对具体部署的浸泡与 容量测试。