Method _simulation_loop

backend/core.py:586–644

仿真主循环

(self)

        self.simulation_thread.start()
    
    def _simulation_loop(self):
        """仿真主循环"""
        last_time = time.time()
        error_count = 0
        max_consecutive_errors = 10
        
        while self.running:
            try:
                current_real_time = time.time()
                delta_real = current_real_time - last_time
                last_time = current_real_time
                
                # 仿真时间推进
                delta_sim = delta_real * TIME_SCALE
                
                with self.lock:
                    self.current_time += delta_sim
                    
                    # 生成背景任务
                    if self.background_task_enabled:
                        self._generate_background_tasks()
                    
                    # 更新资源利用率统计
                    self._update_resource_utilization()
                    
                    # ⭐ 更新决策指标
                    self._update_decision_metrics()
                    
                    # 更新传输任务
                    self._update_transmissions(delta_sim)
                
                # 成功执行，重置错误计数
                error_count = 0
                time.sleep(0.01)  # ⭐ 10ms更新间隔，提高动画流畅度
                
            except Exception as e:
                error_count += 1
                import traceback
                tb = traceback.format_exc()
                _core_logger.error(
                    "仿真循环异常",
                    error=str(e),
                    error_count=error_count,
                    max_consecutive_errors=max_consecutive_errors,
                    traceback=tb,
                )
                # ⭐ 可观测：保留最近的循环异常（供调试接口查询），不静默吞掉
                recent = getattr(self, "_loop_errors", [])
                recent.append({"time": time.time(), "error": str(e), "traceback": tb})
                self._loop_errors = recent[-20:]

                if error_count >= max_consecutive_errors:
                    _core_logger.critical(
                        "连续错误超过阈值，仿真循环终止",
                        max_consecutive_errors=max_consecutive_errors,
                    )
                    break