def check_responsiveness(self):"""优化后的响应性检查，减少系统调用"""if not self.pid or not self.is_running():return Falsetry:# 减少系统调用频率，通过时间戳控制current_time = time.time()if current_time - self.last_check_time < self.min_check_interval:return self.last_responsive  # 返回缓存结果process = psutil.Process(self.pid)# 一次调用获取多个信息，减少系统调用with process.oneshot():  # oneshot模式批量获取信息cpu_percent = process.cpu_percent(interval=None)  # 不阻塞获取memory_percent = process.memory_percent()status = process.status()create_time = process.create_time()# 业务逻辑保持不变...self.last_check_time = current_timeself.last_responsive = resultreturn resultexcept Exception as e:# 异常处理return False

def check_responsiveness(self):"""多维度判断程序状态"""if not self.pid or not self.is_running():return Falsetry:process = psutil.Process(self.pid)with process.oneshot():cpu_percent = process.cpu_percent(interval=None)memory_percent = process.memory_percent()status = process.status()io_counters = process.io_counters()  # 获取I/O信息# 计算I/O变化（需要保存上一次的I/O状态）io_change = (io_counters.read_bytes - self.last_read_bytes + io_counters.write_bytes - self.last_write_bytes)self.last_read_bytes = io_counters.read_bytesself.last_write_bytes = io_counters.write_bytes# 多条件判断：CPU低但I/O有活动可能是I/O密集型程序is_responsive = True# 连续3次检测到异常才判定为卡死if status == psutil.STATUS_NOT_RESPONDING:self.unresponsive_count += 1if self.unresponsive_count >= 3:is_responsive = Falseelif cpu_percent < 0.1 and io_change < 1024:  # 同时检查I/Oself.unresponsive_count += 1if self.unresponsive_count >= 3:is_responsive = Falseelse:self.unresponsive_count = 0  # 重置计数器return is_responsiveexcept Exception as e:return False

import threading
from queue import Queueclass AppMonitor:def __init__(self, app_path, check_interval=5, max_response_time=10):# 其他初始化代码...self.log_queue = Queue()self.log_thread = threading.Thread(target=self._process_logs, daemon=True)self.log_thread.start()self.monitor_thread = Noneself.running = Falsedef _process_logs(self):"""异步处理日志写入"""while True:log_entry = self.log_queue.get()if log_entry is None:  # 退出信号breaklevel, message = log_entryif level == 'info':logging.info(message)elif level == 'warning':logging.warning(message)elif level == 'error':logging.error(message)self.log_queue.task_done()def monitor(self, auto_restart=True):"""使用线程进行异步监测"""self.running = Trueself.monitor_thread = threading.Thread(target=self._monitor_loop, args=(auto_restart,))self.monitor_thread.start()def _monitor_loop(self, auto_restart):"""实际的监测循环，在单独线程中运行"""while self.running:# 监测逻辑...time.sleep(self.check_interval)

def load_config(self, config_file):"""加载针对特定程序的配置"""try:with open(config_file, 'r') as f:config = json.load(f)# 根据程序类型设置不同参数if config.get('app_type') == 'cpu_intensive':self.min_check_interval = 2self.cpu_threshold = 5  # CPU密集型程序阈值更高elif config.get('app_type') == 'io_intensive':self.min_check_interval = 4self.cpu_threshold = 1   # I/O密集型程序CPU阈值更低self.io_threshold = 1024  # 设置I/O阈值# 其他配置...return Trueexcept Exception as e:self.log_queue.put(('error', f"加载配置失败: {str(e)}"))return False

def __init__(self, app_path, check_interval=5, max_response_time=10):# 其他初始化...self.log_rotation_size = 10 * 1024 * 1024  # 10MBself.log_counter = 0self.max_history_records = 100  # 限制历史记录数量self.history = []def _check_log_rotation(self):"""检查并轮转日志文件"""if os.path.getsize("app_monitor.log") > self.log_rotation_size:# 轮转日志timestamp = datetime.now().strftime("%Y%m%d%H%M%S")os.rename("app_monitor.log", f"app_monitor_{timestamp}.log")# 重新配置日志处理器self._reconfigure_logging()def _add_history(self, record):"""添加历史记录并限制数量"""self.history.append(record)if len(self.history) > self.max_history_records:# 移除最旧的记录self.history.pop(0)