执行摘要

• 一句话：将 max_concurrent_batches 集中到 VllmConfig
• 推荐动作：本 PR 展示了一种将 executor 特异性逻辑收敛到统一配置类中的重构手法，适合作为 vLLM V1 向 V2 演进过程中配置集中化的参考样例。建议关注其如何通过 PropertyMock 在测试中模拟配置行为。

功能与动机

当前 max_concurrent_batches 方法定义在 model executor 接口上，从逻辑上讲它更适合作为一个集中式的配置派生方法，而不应绑定于特定的 executor 实现。该方法已被 core engine 使用，且很快还需要被 V2 model runner 消费。

实现拆解

1. 在 vllm/config/vllm.py 的 VllmConfig 类中新增 max_concurrent_batches 属性，基于 parallel_config.pipeline_parallel_size 和 scheduler_config.async_scheduling 计算；
2. 从 vllm/v1/executor/abstract.py 以及 multiproc_executor.py、ray_executor.py、uniproc_executor.py 中移除重复的 max_concurrent_batches 定义，其中多进程执行器还移除了不再需要的 cached_property 导入；
3. 调整 vllm/v1/engine/core.py 中的引用路径，使其通过 VllmConfig 获取该值；
4. 更新测试文件 tests/v1/engine/test_engine_core.py，使用 unittest.mock.PropertyMock 模拟 VllmConfig.max_concurrent_batches 以覆盖异步调度间的并发行为；同时清理了其他测试文件（如 conftest.py、test_engine_core_client.py）中不再需要的 stub 定义。

关键文件：

• vllm/config/vllm.py（模块 配置层；类别 source；类型 core-logic；符号 max_concurrent_batches）: 新增 max_concurrent_batches 属性的核心位置，决定了并发 batch 数的计算逻辑。
• vllm/v1/executor/multiproc_executor.py（模块 多进程执行器；类别 source；类型 core-logic；符号 max_concurrent_batches）: 移除了重复的 max_concurrent_batches cached_property 定义，并清理了不再使用的 cached_property 导入。
• vllm/v1/executor/ray_executor.py（模块 Ray 执行器；类别 source；类型 core-logic；符号 max_concurrent_batches）: 移除了 max_concurrent_batches property 定义，逻辑由 VllmConfig 统一负责。
• vllm/v1/executor/uniproc_executor.py（模块 单进程执行器；类别 source；类型 core-logic；符号 max_concurrent_batches）: 移除了重复的 max_concurrent_batches cached_property，并清理了 cached_property 导入。
• vllm/v1/executor/abstract.py（模块 执行器抽象；类别 source；类型 core-logic；符号 max_concurrent_batches）: 删除了抽象基类中的默认 max_concurrent_batches property，强制所有使用者通过 VllmConfig 获取。
• tests/v1/engine/test_engine_core.py（模块 引擎核心测试；类别 test；类型 test-coverage；符号 max_concurrent_batches）: 测试中模拟 VllmConfig.max_concurrent_batches 以验证引擎核心在非异步调度场景下的并发处理，移除了之前 DummyExecutor 中的 stub 属性。

关键符号：VllmConfig.max_concurrent_batches

关键源码片段

vllm/config/vllm.py

新增 max_concurrent_batches 属性的核心位置，决定了并发 batch 数的计算逻辑。

@property
def max_concurrent_batches(self) -> int:
    # PP 需要 PP-size 个并发 batch 来填充流水线。
    # 异步调度需要 2 个并发 batch 以重叠执行。
    pp_size = self.parallel_config.pipeline_parallel_size
    if pp_size > 1:
        return pp_size
    return 2 if self.scheduler_config.async_scheduling else 1

评论区精华

该 PR 仅有一条审核批准，无 review 讨论。

• 暂无高价值评论线程

风险与影响

• 风险：本次变更为纯重构，仅在 VllmConfig 中新增了一个计算方法，并删除了 executor 中的重复逻辑，不改变任何行为。测试已覆盖异步/非异步调度两种场景，回归风险极低。唯一可能的风险是若外部代码直接引用 executor 上的 max_concurrent_batches 属性，则需要改为通过 VllmConfig 访问，但 vLLM 核心内部已同步更新。
• 影响：对用户无感知；对开发者而言，max_concurrent_batches 现已成为配置基础设施的一部分，任何需要获取并发 batch 上限的模块均可通过 vllm_config.max_concurrent_batches 获得，无需依赖 executor 实例。这将方便 V2 model runner 的后续接入。
• 风险标记：配置集中化, 无行为变更

关联脉络

• 暂无明显关联 PR