### 使用 `concurrent.futures` 实现 Python 并发连接多个交换机 为了实现并发连接多个交换机的功能，可以使用 `concurrent.futures.ThreadPoolExecutor` 来管理线程池。这种方法允许我们异步执行任务而无需手动管理线程生命周期。以下是一个完整的示例代码，演示如何通过 SSH 连接到多个交换机并获取其配置信息。 #### 示例代码：使用 ThreadPoolExecutor 并发连接多个交换机 ```python from concurrent.futures import ThreadPoolExecutor, as_completed from netmiko import ConnectHandler, NetMikoTimeoutException, NetMikoAuthenticationException def fetch_switch_config(switch): """Connects to a switch via SSH and retrieves configuration.""" try: with ConnectHandler(**switch) as conn: config = conn.send_command("show running-config") # 获取运行配置 return {"status": "success", "data": config} except NetMikoTimeoutException: return {"status": "error", "message": "Connection timeout"} except NetMikoAuthenticationException: return {"status": "error", "message": "Authentication failed"} # 配置交换机列表 switches = [ { "device_type": "cisco_ios", "ip": "192.168.1.1", "username": "admin", "password": "password" }, { "device_type": "cisco_ios", "ip": "192.168.1.2", "username": "admin", "password": "password" } ] # 创建线程池并提交任务 with ThreadPoolExecutor(max_workers=5) as executor: futures = [executor.submit(fetch_switch_config, switch) for switch in switches] # 处理结果 for future in as_completed(futures): result = future.result() if result["status"] == "success": print(f"Configuration retrieved successfully:\n{result['data'][:100]}...") # 打印前100字符作为示例 else: print(f"Failed to retrieve configuration: {result['message']}") ``` 在此代码中，定义了一个函数 `fetch_switch_config()` 用于单独处理每个交换机的连接和数据检索过程[^3]。随后创建了一个包含所有目标交换机信息的列表，并将其传递给 `ThreadPoolExecutor` 的实例化对象以启动多线程操作。最后通过迭代已完成的任务 (`as_completed`) 输出每台设备的结果状态及其部分内容摘要。 --- #### 关于事件驱动模型与阻塞IO的关系 值得注意的是，在某些情况下可能会混合使用同步和异步方法来解决复杂场景中的问题。然而正如之前提到过的那样，“集成多线程、阻塞I/O代码与非阻塞I/O代码时会显得有些笨拙”，因为这两种风格本质上遵循不同的设计哲学[^2]。因此推荐尽量保持一致性的编码模式以免增加不必要的维护成本和技术债务。 另外考虑到现代硬件资源日益充沛的趋势下，适当提高最大工作者数（即设置更高的 `max_workers` 参数值），往往能够带来更好的整体吞吐表现；不过具体数值还需依据实际环境测试得出最优解。 ---