63.1 async/await . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 327 63.2 Futures . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 328 63.3 Runtimes . 330 63.5 异步通道 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 330 64 Futures Control Flow 332 64.1 加入 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 进行裸机（嵌入式）开发。课程内容涵盖微控制器和应用 处理器。 • 并发：为期一天的课程，介绍 Rust 中的并发性。我们将涵盖传统并发（使用线程和互斥锁进行抢占 式调度）和 async/await 并发（使用 futures 进行协作式多任务处理）。 非目标 Rust 是一门庞大的语言，短短几天的课程无法覆盖其全部内容。本课程不包括以下内容： • 学习如何开发宏：请参阅 Rust Book 的第 19.5 章

. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 375 17.1. Futures 和 async 语法 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 385 17.3. 使用任意数量的 futures . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 探索如何使用异步模型来解决第十六章中遇到的一些挑战 • 了解多线程和异步如何互补，在很多场景中你甚至可以同时使用两者 377/562Rust 程序设计语言 简体中文版 Futures 和 async 语法 Rust 异步编程的关键元素是 futures 和 Rust 的 async 与 await 关键字。 future 是一个现在可能还没有准备好但将在未来某个时刻准备好的值。（相同的概念也出现在 很多语言中，有时被称为

{ let f = foo(&mut buf); let pinned = std��pin��pin!(f); let _ = futures��poll!(pinned); pinned.cancel(); } �� use buf here shoud be safe } 另⼀种“⾊彩”的 run_to_completion_futures https://github.com/Matthias247/rfcs/blob/e7fd7042f8069e9126e2096156d2abe3c38e781b/text/0000-run-to-completion-async-fn.md Async destructors, async genericity and completion futures https://sabrinajewson https://carllerche.netlify.app/2021/06/17/six-ways-to-make-async-rust-easier/ 引⽤ FUTURES CONCURRENCY III: SELECT! https://blog.yoshuawuyts.com/futures-concurrency-3/#concurrent-stream-processing-with-stream-merge Thank

切换协程 14.5 通道、超时和计时器（Ticker） 14.6 协程和恢复（recover） 14.7 新旧模型对比：任务和worker 14.8 惰性生成器的实现 14.9 实现 Futures 模式 第 15 章 网络，模板和网页应用 15.1 tcp服务器 15.2 一个简单的网页服务器 15.3 访问并读取页面 15.4 写一个简单的网页应用 第 16章 常见的陷阱与错误 好书，相关内容已获得作者同意根 据当前 Go 语言版本进行修改而不作出特别声明。 该翻译版本已获得原作者（Ivo Balbaert）本人授权，并表示支持开源事业的发展！ 14.9 实现 Futures 模式 如果你喜欢本书 《Go入门指南》，你可以参与到本书的翻译或纠正工作中来，具体请联系【无闻 E-mail： u#gogs.io】，一同完善本书并帮助壮大 Go 语言在国内的学习群体，给大家提供更好的学习资源。 切换协程 14.5 通道、超时和计时器（Ticker） 14.6 协程和恢复（recover） 14.7 新旧模型对比：任务和worker 14.8 惰性生成器的实现 14.9 实现 Futures 模式 14 协程（goroutine）与通道（channel） 链接 第 14 章 协程（goroutine）与通道（channel） - 377 - 本文档使用 书栈(BookStack

生产实践 – Cancellation 生产实践 – Cancellation try_join_all!(a,b,c…) https://docs.rs/futures/latest/futures/future/fn.try_join_all.html 生产实践 – Cancellation try_join_all!(a,b,c…) join_all!(a,b,c…)

OrderedDict collections.Counter Python的现状 Python 3.0 Python 3.1 Python 3.2 2011.2 concurrent.futures Python的现状 Python 3.0 Python 3.1 Python 3.2 Python 3.3 2012.9 yield from unittest.mock Python3的新特性和改进——易用性的提升 Assignment expressions（Python 3.8） Python3的新特性和改进——易用性的提升 标准库：concurrent.futures Python3的新特性和改进——易用性的提升 标准库：pathlib Python3的新特性和改进——易用性的提升 标准库：dataclasses 2 Python3的新特性和改进

Asynchronous IO ○ mio ● Storage engine ○ RocksDB ● RPC ○ Protobuf PRC ● Metrics ○ Prometheus ● futures-rs ○ WIP ● rust-grpc ○ WIP eventloop scheduler scheduler raft router coprocessor worker worker

spawn_blocking 提交耗时任务 • C FFI 调用时，要关注上下文的线程安全性。 • 多个运行时之间使用 Channel 通信，降低锁使用范围。 Tokio - Graceful Stop • futures::future::Abortable 可用于短路一个 stream • tokio_util::sync::CancellationToken 可用于向一个或多个任务发出取 消信号， Task

回调在诸如 JavaScript 之类的事件循环体系结构中非常常见，但即使在那里， 通常人们已经转而使用其他方法，例如 promises 或反应式扩展。 Future、 Promise 及其他 futures 或 promises 背后的想法（这也可能会根据语言/平台而有不同的术 语），是当我们发起调用的时候，我们承诺在某些时候它将返回一个名为 Promise 的可被操作的对象。 fun postItem(item: 一系列扩展，允许我们对数据进行操作。 在方法上它与 Futures 非常相似，但是人们可以将 Future 视为一个离散元素， 而 Rx 返回一个流。然而，与前面类似，它还介绍了一种全新的思考我们的编 程模型的方式，著名的表述是： “一切都是流，并且它是可被观察的” 这意味着处理问题的方式不同，并且在编写同步代码时从我们使用的方式发生 了相当大的转变。与 Futures 相反的一个好处是，它被移植到这么多平台，通

2”); return “step2 result”; }); ListenableFuture> future1And2 = Futures.allAsList(future1, future2); Futures.addCallback(future1And2, new FutureCallback>() { @Override System.out.println(“执行 step 3”); return “step3 result”; }); Futures.addCallback(future3, new FutureCallback() { @Override public void