在 Rust 中实现自定义 Future这段代码演示了如何在 Rust 中手动实现一个自定义的Future通过创建一个简单的延迟Delayfuture 来说明核心概念。主要知识点1.Pinmut Self的作用保证结构体在内存中不会被移动本例中Delay只包含Instant和Duration都是Unpin类型编译器自动实现了Unpin因此固定pinning操作实际上是空操作如果结构体包含自引用借用如手写的异步状态机固定会防止首次轮询后的移动避免借用失效2.Poll::PendingvsPoll::Ready返回Poll::Pending告诉执行器我还没完成稍后唤醒我返回Poll::Ready(())表示 future 已完成3.cx.waker()唤醒机制这是安排重新轮询的关键机制必须调用wake()否则执行器永远不会再次轮询future 会挂起生产环境的计时器会向反应器reactor注册本例为简化直接请求立即重新轮询代码实现Delay结构体包含一个截止时间deadlinepoll方法检查当前时间是否达到截止时间已到达 → 返回Poll::Ready(())未到达 → 调用cx.waker().wake_by_ref()并返回Poll::Pending使用示例在异步主函数中等待 10 毫秒验证实际经过的时间注意事项这是一个教学示例采用忙轮询busy-polling方式实际应用中应使用定时器轮timer wheel或反应器模式以提高效率。https://rust-lang-nursery.github.io/rust-cookbook/concurrency/custom_future.htmlRust Actor 模式实现驾驶员位置追踪系统这是一个使用 Tokio 异步运行时实现的 Actor 模式示例用于管理驾驶员位置信息。核心组件Message 枚举定义了 Actor 接收的命令类型UpdateLocation: 更新驾驶员位置包含驾驶员ID、经纬度GetDriverStatus: 查询驾驶员状态通过 oneshot 通道返回结果DriverStatus 结构体存储驾驶员状态信息ID、经纬度坐标、更新次数DriverActorActor 实体拥有数据的所有权运行在独立的任务中使用 HashMap 存储所有驾驶员状态无需ArcMutex因为只有一个任务访问数据run()方法循环接收并处理消息handle_message()方法处理具体的消息逻辑DriverHandle句柄可克隆的句柄持有mpsc::Sender在应用程序中传递和共享提供异步方法update_location(): 发送位置更新命令get_driver_status(): 查询驾驶员状态并等待响应关键特性并发安全通过消息传递避免共享内存无需显式锁可扩展Handle 可克隆并发送到多个任务异步通信使用 mpsc 通道进行命令发送oneshot 通道获取响应简洁的 API外部代码通过 Handle 与 Actor 交互隐藏实现细节示例执行流程主函数演示了多任务并发更新驾驶员位置然后查询不同驾驶员的状态包括不存在的驾驶员返回 None。https://rust-lang-nursery.github.io/rust-cookbook/concurrency/actor.html--From 日报小组 Mike社区学习交流平台订阅Rustcc论坛: 支持rss微信公众号Rust语言中文社区