使用 Rust 实现的基础的List 和 Watch 机制

使用 Rust 实现的基础的 List 和 Watch 机制在软件开发中我们经常需要一种机制来跟踪数据的变化并在变化发生时通知相关的观察者。这种模式被称为“观察者模式”或“发布-订阅模式”。在 Rust 中我们可以利用其所有权系统和并发安全特性实现一个轻量级的 List 和 Watch 机制。本文将带你一步步构建这个基础机制并通过代码示例展示其用法。## 什么是 List 和 Watch 机制想象一下你有一个购物清单List当清单上的商品价格发生变化时你想立刻收到通知Watch。在编程中List 是一个可共享的数据集合Watch 是一种监听器当 List 中的数据发生变化时所有注册的 Watch 都会收到回调通知。这种机制在很多场景下非常有用比如- 实时监控系统状态- 前端状态管理- 游戏中的事件处理- 分布式系统中的配置更新## 基础设计思路我们将用 Rust 实现一个简单的 List 和 Watch 机制。核心思想是1.List保存一个可变的数据列表并提供修改方法。2.Watcher一个闭包或函数当 List 变化时被调用。3.Registry管理所有 Watcher 的注册和通知。由于 Rust 的所有权规则我们需要使用Arc原子引用计数和Mutex互斥锁来安全地共享和修改数据。## 代码实现核心结构我们先定义基本类型和核心结构。为了让代码更直观我们使用std::sync::Arc和std::sync::Mutex。rustuse std::sync::{Arc, Mutex};use std::collections::HashMap;use std::thread;use std::time::Duration;// 定义一个泛型 List可以存储任何 Clone 类型的元素pub struct ListT: Clone { data: ArcMutexVecT, // 共享的可变数据 watchers: ArcMutexHashMapu64, Boxdyn Fn([T]) Send, // 观察者注册表 next_id: ArcMutexu64, // 用于生成唯一 ID}implT: Clone ListT { // 创建一个新的 List pub fn new() - Self { List { data: Arc::new(Mutex::new(Vec::new())), watchers: Arc::new(Mutex::new(HashMap::new())), next_id: Arc::new(Mutex::new(0)), } } // 添加元素到列表并通知所有观察者 pub fn push(self, item: T) { let mut data self.data.lock().unwrap(); data.push(item); self.notify_watchers(data); } // 删除最后一个元素并通知观察者 pub fn pop(self) - OptionT { let mut data self.data.lock().unwrap(); let result data.pop(); if result.is_some() { self.notify_watchers(data); } result } // 注册一个观察者返回一个 ID用于取消注册 pub fn watch(self, callback: Boxdyn Fn([T]) Send) - u64 { let mut id self.next_id.lock().unwrap(); *id 1; let current_id *id; let mut watchers self.watchers.lock().unwrap(); watchers.insert(current_id, callback); current_id } // 取消注册一个观察者 pub fn unwatch(self, id: u64) { let mut watchers self.watchers.lock().unwrap(); watchers.remove(id); } // 通知所有观察者 fn notify_watchers(self, data: VecT) { let watchers self.watchers.lock().unwrap(); for (_, callback) in watchers.iter() { callback(data.as_slice()); } } // 获取当前数据的快照 pub fn snapshot(self) - VecT { let data self.data.lock().unwrap(); data.clone() }}代码解释-data使用ArcMutexVecT存储数据允许多线程安全访问。-watchers是一个HashMap使用u64作为唯一 ID存储可调用的闭包。-push和pop方法在修改数据后调用notify_watchers。-watch方法注册一个闭包并返回一个 ID用于后续取消注册。-unwatch方法通过 ID 移除观察者。## 使用示例监控字符串列表现在让我们用这个 List 来监控一个字符串列表的变化。我们将创建两个观察者分别打印不同的信息。rustfn main() { // 创建一个存储字符串的 List let list List::new(); // 注册第一个观察者打印新列表内容 let id1 list.watch(Box::new(|data| { println!(观察者1: 列表更新了当前内容: {:?}, data); })); // 注册第二个观察者只打印元素个数 let id2 list.watch(Box::new(|data| { println!(观察者2: 当前有 {} 个元素, data.len()); })); // 添加一些元素 println!(添加元素...); list.push(苹果.to_string()); list.push(香蕉.to_string()); list.push(橘子.to_string()); // 移除一个元素 println!(\n移除元素...); list.pop(); // 取消第一个观察者 println!(\n取消观察者1...); list.unwatch(id1); // 再次添加元素只有观察者2会收到通知 println!(再次添加元素...); list.push(葡萄.to_string()); // 获取最终快照 let final_data list.snapshot(); println!(\n最终列表: {:?}, final_data);}运行结果预期输出添加元素...观察者1: 列表更新了当前内容: [苹果]观察者2: 当前有 1 个元素观察者1: 列表更新了当前内容: [苹果, 香蕉]观察者2: 当前有 2 个元素观察者1: 列表更新了当前内容: [苹果, 香蕉, 橘子]观察者2: 当前有 3 个元素移除元素...观察者1: 列表更新了当前内容: [苹果, 香蕉]观察者2: 当前有 2 个元素取消观察者1...再次添加元素...观察者2: 当前有 3 个元素最终列表: [苹果, 香蕉, 葡萄]这个示例清晰地展示了- 每次修改数据时所有观察者都会被调用。- 取消注册后观察者不再接收通知。- 可以通过snapshot获取当前数据的副本。## 高级用法多线程安全与性能考虑在实际应用中我们可能需要在多线程环境中使用这个 List。Rust 的Arc和Mutex已经保证了线程安全但需要注意性能问题。例如频繁的锁竞争可能成为瓶颈。下面是一个多线程示例展示如何在不同线程中操作 Listrustuse std::thread;fn main() { let list Arc::new(List::new()); // 在子线程中添加元素 let list_clone Arc::clone(list); let thread1 thread::spawn(move || { for i in 0..3 { list_clone.push(format!(线程1-{}, i)); thread::sleep(Duration::from_millis(100)); } }); // 在主线程中注册观察者 let id list.watch(Box::new(|data| { println!(主线程观察者: 列表长度 {}, data.len()); })); // 在子线程中移除元素 let list_clone2 Arc::clone(list); let thread2 thread::spawn(move || { thread::sleep(Duration::from_millis(250)); list_clone2.pop(); list_clone2.pop(); }); thread1.join().unwrap(); thread2.join().unwrap(); // 取消观察者 list.unwatch(id); println!(最终数据: {:?}, list.snapshot());}输出示例主线程观察者: 列表长度 1主线程观察者: 列表长度 2主线程观察者: 列表长度 3主线程观察者: 列表长度 2主线程观察者: 列表长度 1最终数据: [线程1-0]这个示例显示了- 多线程环境下观察者仍然能正确收到通知。- 锁机制保证了数据一致性但要注意死锁本例中不会发生因为锁持有时间很短。## 优化建议虽然我们的实现功能完整但还有改进空间1.使用RwLock替代Mutex如果读操作远多于写操作RwLock可以提供更好的并发性能。2.批量通知如果连续多次修改可以合并通知避免不必要的回调。3.异步支持对于 I/O 密集型应用可以改为异步回调避免阻塞主线程。4.类型安全当前watchers使用Boxdyn Fn存在动态分发开销。如果知道具体类型可以用泛型优化。## 总结本文通过 Rust 实现了一个基础但完整的 List 和 Watch 机制。我们学习了- 如何使用Arc和Mutex实现线程安全的数据共享。- 观察者模式的核心结构List 存储数据Watcher 接收通知。- 如何注册、取消注册观察者以及如何在数据变化时广播通知。- 多线程环境下的使用方法和注意事项。这个机制虽然简单但已经可以满足很多实际需求比如实时数据监控、事件驱动编程等。你可以在此基础上扩展比如增加条件过滤、支持异步回调、或者集成到 Web 框架中。Rust 的所有权系统和并发原语让这种实现既安全又高效非常适合构建可靠的后台服务。希望这篇文章能帮助你理解 Rust 中的观察者模式设计并给你在实际项目中带来启发。如果你有任何问题或改进建议欢迎在评论区交流