纠正了 mock_airport的日志部分没有使用logger 记录的bug
This commit is contained in:
parent
b00190ee04
commit
e6e1965289
@ -2024,7 +2024,8 @@ class BackgroundUpdateManager:
|
||||
self.running = True
|
||||
self.update_thread = threading.Thread(target=self._update_loop, daemon=True)
|
||||
self.update_thread.start()
|
||||
logging.info("后台更新管理器已启动")
|
||||
logger.info("后台更新管理器已启动")
|
||||
logger.handlers[0].flush() # 立即刷新日志
|
||||
|
||||
def stop(self):
|
||||
"""停止后台更新线程"""
|
||||
@ -2051,11 +2052,19 @@ class BackgroundUpdateManager:
|
||||
update_vehicle_position(vehicle, UPDATE_INTERVAL)
|
||||
vehicle["time"] = int(current_time * 1000)
|
||||
|
||||
# 定期刷新日志到文件(每10个周期)
|
||||
if int(current_time) % 10 == 0:
|
||||
for handler in logger.handlers:
|
||||
handler.flush()
|
||||
|
||||
# 休眠到下一个更新周期
|
||||
time.sleep(UPDATE_INTERVAL)
|
||||
|
||||
except Exception as e:
|
||||
logger.error(f"后台更新出错: {str(e)}")
|
||||
# 错误发生时立即刷新日志
|
||||
for handler in logger.handlers:
|
||||
handler.flush()
|
||||
time.sleep(1.0) # 出错时短暂休眠后继续
|
||||
|
||||
# 全局后台更新管理器实例
|
||||
|
||||
Loading…
Reference in New Issue
Block a user