Rust 开发者大会 Await-Tree Async Rust 可观测性的灵丹妙药 赵梓淇 Bugen Zhao Await-Tree Async Rust 可观测性的灵丹妙药 Await-Tree 的 设计原理与实现 2 回顾 Async Rust 的设计与痛点 1 Await-Tree 的 应用与真实案例 3 Await-Tree Async Rust 可观测性的灵丹妙药 可观测性的灵丹妙药 Await-Tree 的 设计原理与实现 2 回顾 Async Rust 的设计与痛点 1 Await-Tree 的 应用与真实案例 3 Async Rust 的优势 • 异步编程的共同优势 • async/await 关键字 • 用户态调度 • Async Rust 的独特优势 • Ownership 与 Lifetime • 无栈协程 Async Rust 回顾 回顾 Rust 的无栈协程抽象 — Future Async Rust 回顾 • 通过 poll 驱动的状态机 • 组合嵌套为调度单元： Task • async fn 语法糖 Async Rust 观测与调试的痛点 Async Rust 回顾 • 特性： Future 灵活的可组合性 • 任意定制 Poll 的执行逻辑 (Join / Select / Timeout) • 动态的调用关系

之类的 async runtime 中执行一些特别的 WASM 时就会遇到 WASM 阻塞 tokio 最终导致服务不可用的情况。 阻塞示例 WASM 使用场景和问题 利用语言本身 Async 机制 因为 Rust 的 async 机制是无栈协程，会将 async 部分在编译时隐式转换成一个 Future。 所以我们可以利用这一点来实现一个 Async 的 Wasm。 Async Wasm Photo / image / chart 利用本身 Async 机制 自行实现 Async Runtime Async 的 Wasm • 在 wasm 中把 future 存入固定内存处。 • 导出 poll 函数给 host 调用。 • 把 host function 包装成自定义 Future。 • 实现简单 利用本身 Async 机制 优点 • 方案不通用（wasm 局限于某一种语言） 无法与现有生态配合 缺点 Async 的 Wasm 基于 fiber / ucontext Async Wasm 解决方案 wasmtime-fiber 是一个通过内联汇编，保存当前寄存 器和栈数据来实现有栈协程的 rust 库。 wasmtime-fiber Ucontext 和 fiber 功能相同，但是 linux 的系统库。 ucontext 执行流程 Async Wasm 解决方案

介绍 ThinkJS 是一款使用 ES6/7 特性全新开发的 Node.js MVC 框架，使用 ES7 中 async/await ，或者 ES6 中的 */yield 特性彻底解决了 Node.js 中异步嵌套的问题。同时吸收了国内外众多框架的设 计理念和思想，让开发 Node.js 项目更加简单、高效。 使用 ES6/7 特性来开发项目可以大大提高开发效率，是趋势所在。并且新版的 Node 所有的特性，无需担心哪些特性当前版本不支 持。尤其是使用 async/await 或者 */yield 来解决异步回调的问题。 //user controller, home/controller/user.js export default class extends think.controller.base { //login action async loginAction(self){ //这⾥里里可以通过post⽅方法获取所有的数据，数据已经在logic⾥里里做了了校验 let data = this.post(); //⽤用户名去匹配数据库中对应的条⽬目 let result = await this.model('user').where({name: data.name}).find(); if(!validateLogin(result)){ return this

Map 数据结构 Proxy Reflect Promise 对象 Iterator 和 for...of 循环 Generator 函数的语法 Generator 函数的异步应用 async 函数 Class 的基本语法 Class 的继承 Decorator Module 的语法 Module 的加载实现 编程风格 读懂规格 ArrayBuffer 2 1.28 // 42, "OK", [867, 5309] 上面代码可以快速提取 JSON 数据的值。 （5）函数参数的默认值 jQuery.ajax = function (url, { async = true, beforeSend = function () {}, cache = true, complete = function () {}, crossDomain 呢？回答是可以的，并且还有两种写法。第一种写法是用 async 函数 来写。 const f = () => console.log('now'); (async () => f())(); console.log('next'); // now // next 上面代码中，第二行是一个立即执行的匿名函数，会立即执行里面的 async 函 数，因此如果 f 是同步的，就会得到同步的结果；如果

ThinkJS ����� ES6/7 ������� Node.js MVC ����� ES7 � async/await ��� ES6 �� */yield ������� Node.js ���������������������������� ����� Node.js ���������� �� ES6/7 ����������������������������� Node �������������������������� � async/await �� */yield ����������� ThinkJS 2.0 Documentation ���� �� �� �� ES6/7 ������� ���������� ES6 �� class , export , let �� ES7 �� async � await ���� ���������� Session Session ���������� async/await �������������� � Babel ������������� Node.js ������ ������������������������������������������� ���� development � testing � prodution 3 ��������������������� ���

. . . . . . . . . . . . . . . . . . . . . . . . . . . 320 XIV 并发：下午 326 63 异步 Rust 327 63.1 async/await . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 327 63.2 Futures . . . 选择 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 333 65 关于 async/await 的误区 335 65.1 阻塞执行器 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 335 . . . . . . . . . . . . . . . . . . . . . . . . . . . 339 66 习题 342 66.1 Dining Philosophers — Async . . . . . . . . . . . . . . . . . . . . . . . . . . 342 66.2 广播聊天应用 . . . . . . . . . . . . . .

支持 Middleware、Extend、Adapter 等扩展方式 基于 Koa 2.x 开发 性能优异，单元测试覆盖程度高 内置自动编译、自动更新机制，方便开发环境快速开发 直接使用 async/await 解决异步问题，不支持 */yield 架构 ThinkJS 3.0 Documentation 快速入门 快速入门 借助 ThinkJS 提供的脚手架，可以快速的创建一个项目。为了可以使用更多的 config(key, value) // src/bootstrap/worker.js //HTTP 服务启动前执⾏行行 think.beforeStartServer(async () => { const config = await think.model('config').select(); think.config('userConfig', config); //从数据库中将配置读取出来，然后设置 Action 之前调用的，这样就可以在其中做一些处理。 module.exports = class extends think.Controller { async __before(){ const userInfo = await this.session('userInfo'); //获取⽤用户的 session 信息，如果为空，返回 false 阻⽌止后续的⾏行行为继续执⾏行行

373 17. Async 和 await . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 375 17.1. Futures 和 async 语法 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 378 17.2. 并发与 async . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 405 17.5. 深入理解 async 相关的 traits . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .

第三届中国Rust开发者⼤会 Rust 是否需要另⼀种“⾊彩”的 Future？ 郭⼦兴，字节跳动服务框架团队研发⼯程师。 作者 Rust 是否需要另⼀种“⾊彩”的 Future？ 标题 Rust 编译器将 async 块翻译成由标准库提供的 Future 类型，⽤户可以⽅便地通过⾃定义 Future 以实现⾮阻塞 的 IO 或并发控制语义。异步执⾏器被允许在任意时刻删除⽣成的 Future 实例以取消正在执⾏的异步操作，但取消 } 取消 Future ⽤户可以突破 async / await 封装⾃⼰的 Future 类型，被构造的 Future 类型不要求返 回完成即可被析构。 async fn task_one() { /� ��� ⁎/ } async fn task_two() { /� ��� ⁎/ } async fn race_tasks() { } } Select: 基于取消的并发控制语义 select! 是常⻅的并发控制语义，它的语义当 其中⼀个分⽀完成时即返回，⽽不必等待所有 Future 实例完成。 async fn listen(listener: TcpListener) { loop { let t1 = listner.accept(); let

JSONResponse from starlette.routing import Route, Mount from pywebio.platform.fastapi import webio_routes async def homepage(request): return JSONResponse({'hello': 'world'}) app = Starlette(routes=[ Route('/' 要使用基于协程的会话，需要使用 async 关键字将任务函数声明为协程函数， 并使用 await 语法调用PyWebIO输入函数: from pywebio.input import * from pywebio.output import * from pywebio import start_server async def say_hello(): name = await input("what's put_text('Hello, %s' % name) start_server(say_hello, auto_open_webbrowser=True) 在协程任务函数中，也可以使用 await 调用其他协程或标准库 asyncio [https://docs.python.org/3/library/asyncio.html] 中的可等待对象( awaitable objects [https://docs