Class TestHighUtilizationBehavior

tests/load/test_stress_engine.py:415–458

验证资源紧张（高占用）下引擎行为符合预期。

class TestHighUtilizationBehavior:
    """验证资源紧张（高占用）下引擎行为符合预期。"""

    def test_no_exception_under_simulated_load(self, stepped_engine):
        """步进推进 + 批量提交，引擎在资源紧张前后均不抛出异常。"""
        # 提交大量低优先级请求
        errors = []
        for i in range(100):
            try:
                payload = {
                    "data_type": "DATA_SLICE",
                    "data_size": 500,
                    "priority": 1 + (i % 3),
                    "max_delay": 300,
                }
                stepped_engine.submit_request(payload)
            except Exception as exc:
                errors.append(exc)

        assert len(errors) == 0, f"步进负载下出现异常: {errors[:3]}"

    def test_high_priority_vs_low_priority_under_load(self, stepped_engine):
        """在连续提交后，高/低优先级请求均能正常返回结果字典（不崩溃）。"""
        hi_results = [stepped_engine.submit_request(dict(_HIGH_PRI_PAYLOAD)) for _ in range(40)]
        lo_results = [stepped_engine.submit_request(dict(_LOW_PRI_PAYLOAD)) for _ in range(40)]

        for r in hi_results + lo_results:
            assert isinstance(r, dict), "submit_request 必须始终返回字典"

    def test_stats_remain_consistent_under_stepped_load(self, stepped_engine):
        """步进 + 批量提交后，统计计数守恒。"""
        # 额外步进 30 秒
        advance_engine(stepped_engine, total_seconds=30.0, step=10.0)

        for _ in range(80):
            stepped_engine.submit_request(dict(_HIGH_PRI_PAYLOAD))

        stats = stepped_engine.stats
        total = stats["total_requests"]
        accepted = stats["accepted_requests"]
        rejected = stats["rejected_requests"]
        assert total == accepted + rejected, (
            f"步进后计数不守恒: total={total}, accepted={accepted}, rejected={rejected}"
        )