执行摘要

• 一句话：将 scheduler.py 的模块级辅助函数移到独立文件
• 推荐动作：值得精读：这是一个教科书式的纯机械重构案例，展示了如何在不改变行为的前提下系统性地提取代码、更新导入关系，并保持字节级等价。对于希望改善大型文件结构的团队有很好的参考价值。

功能与动机

PR body 指出这是对 scheduler.py 中模块级自由项的纯机械迁移，每项都是字节相同地迁移，不重命名、不改签名。目标是将 embedding 结果、dflash 校验、看门狗、空闲睡眠、健康检查以及输出发送等逻辑从庞大的 scheduler.py 中剥离，让调度器核心更聚焦。

实现拆解

1. 将 EmbeddingBatchResult 数据类及其 copy_to_cpu 方法移至 managers/utils.py，与已有的 GenerationBatchResult 相邻，并一并移入 is_health_check_generate_req 函数（修复反向导入问题）。

2. 将 validate_dflash_request 函数移至 speculative/dflash_utils.py，与 DFLASH 工具函数放在一起。

3. 将 create_scheduler_watchdog 函数（含 dump_info 闭包）移至 scheduler_components/invariant_checker.py，紧邻已有检查逻辑。

4. 将 IdleSleeper 类抽取为独立文件 scheduler_components/idle_sleeper.py，对应 idle_sleeper 组件。

5. 将 SenderWrapper 类抽取为独立文件 scheduler_components/output_sender.py，对应输出发送组件。

6. 在 scheduler.py 中删除原有定义，改为从新位置导入；同步调整 batch_result_processor.py、metrics_reporter.py、tokenizer_manager.py 等文件的导入路径。

关键文件：

• python/sglang/srt/managers/scheduler.py（模块 调度器；类别 source；类型 core-logic；符号 EmbeddingBatchResult, copy_to_cpu, validate_dflash_request, create_scheduler_watchdog）: 主变更文件，删除了 151 行模块级定义，仅保留核心调度逻辑，大幅缩减文件体积。
• python/sglang/srt/managers/scheduler_components/idle_sleeper.py（模块 空闲睡眠；类别 source；类型 core-logic；符号 IdleSleeper, init, maybe_sleep）: 新文件，封装了 IdleSleeper 类，用于降低空闲时 CPU 功耗。
• python/sglang/srt/managers/scheduler_components/output_sender.py（模块 输出发送；类别 source；类型 core-logic；符号 SenderWrapper, init, send_output）: 新文件，封装了 SenderWrapper 类，用于通过 ZMQ 发送输出对象。
• python/sglang/srt/managers/utils.py（模块 工具函数；类别 source；类型 core-logic；符号 EmbeddingBatchResult, copy_to_cpu, is_health_check_generate_req）: 接收了 EmbeddingBatchResult 数据类、copy_to_cpu 方法和 is_health_check_generate_req 函数。
• python/sglang/srt/managers/scheduler_components/invariant_checker.py（模块 不变性检查；类别 source；类型 core-logic；符号 create_scheduler_watchdog, dump_info）: 接收了 create_scheduler_watchdog 函数（含 dump_info 闭包），与现有检查逻辑合并。
• python/sglang/srt/speculative/dflash_utils.py（模块 DFLASH 工具；类别 source；类型 core-logic；符号 validate_dflash_request）: 接收了 validate_dflash_request 函数，作为 DFLASH 模块的请求有效性校验。

关键符号：IdleSleeper.maybe_sleep, SenderWrapper.send_output, EmbeddingBatchResult.copy_to_cpu, create_scheduler_watchdog, validate_dflash_request, is_health_check_generate_req

关键源码片段

python/sglang/srt/managers/scheduler_components/idle_sleeper.py

新文件，封装了 IdleSleeper 类，用于降低空闲时 CPU 功耗。

"""idle_sleeper.py — 空闲时降低 CPU 功耗的 poll 机制"""
​
import zmq
​
from sglang.srt.environ import envs
from sglang.srt.observability.req_time_stats import real_time
from sglang.srt.platforms import current_platform
​
​
class IdleSleeper:
    """
    在长空闲时段降低系统功耗。当 sglang 无请求时，通过 zmq.Poller 阻塞等待
    而非忙等，从而节省 CPU 资源并留下散热余量。
    """
​
    def __init__(self, sockets):
        # 注册所有接收 socket 到 Poller
        self.poller = zmq.Poller()
        self.last_empty_time = real_time()
        for s in sockets:
            self.poller.register(s, zmq.POLLIN)
        self.empty_cache_interval = envs.SGLANG_EMPTY_CACHE_INTERVAL.get()
​
    def maybe_sleep(self):
        # 阻塞 1000ms 等待事件，避免忙等
        self.poller.poll(1000)
        # 若超过间隔阈值，主动清空缓存
        if (
            self.empty_cache_interval > 0
            and real_time() - self.last_empty_time > self.empty_cache_interval
        ):
            self.last_empty_time = real_time()
            current_platform.empty_cache()

评论区精华

PR 没有触发实质性 review 讨论，唯一的评论是自动化工具的每日配额提醒。无争议或未解决问题。

• 暂无高价值评论线程

风险与影响

• 风险：风险极低：所有迁移都是字节相同的复制-粘贴，签名和语义完全不变。主要风险在于是否遗漏了调用方导入路径的更新。但 PR 已逐一修改所有引用点（scheduler.py、tokenizer_manager.py、scheduler_components/batch_result_processor.py、metrics_reporter.py），并且 CI 测试通过。后续 PR #25639 进一步删除了变为死代码的 is_work_request 函数，验证了迁移完整性。
• 影响：对用户无功能影响。对开发者而言，若用户代码直接引用了 scheduler.py 中的 EmbeddingBatchResult、IdleSleeper、SenderWrapper 等符号，需将导入语句更新到新位置。不过这些符号原本属于内部模块，外部引用可能性不大。代码库整体模块内聚性提升，未来维护更清晰。
• 风险标记：无功能变更, 导入路径重写, 未新增测试

关联脉络

• PR #25639 Delete the now-unused is_work_request from scheduler.py: 本 PR 的后续清理步骤，删除因迁移变为死代码的 is_work_request 函数。