用途：该技能汇总了基于 Tokio 的高级并发模式，面向需要构建可扩展异步应用的 Rust 开发者，内容以可参考的代码模式为主。
主要能力：扇出/扇入（用 stream 的 buffer_unordered 分发任务并收集结果）；流水线处理（用 mpsc 串联多个 Stage）；限流（基于 Semaphore 的令牌桶）；并行任务执行（try_join! 与 spawn_blocking 处理 CPU 密集工作）；协调关停（CancellationToken 配合 select! 实现层级取消）；异步 trait 模式（async_trait 及手写 Pin<Box<dyn Future>> 两种写法）；共享状态管理（Arc<RwLock<HashMap>>）；工作窃取队列；熔断器（Closed/Open/HalfOpen 状态）；批处理（按批量大小或超时触发）。
使用方式：资料以代码示例呈现，需结合 Rust 项目依赖使用，涉及 futures、tokio、async-trait、tokio-util 等。示例包含具体函数与结构体实现，可直接参考或改写。
适用场景：需要控制并发度、保护外部服务、让任务优雅退出或防止故障扩散的异步系统。
限制：资料未说明安装命令、版本兼容范围、性能指标或收费信息；部分示例（如限流刷新、熔断并发状态判断）仅为模式参考，落地时需自行验证正确性与边界条件。