Terrarum::异世界丨居正博客
·
在 Cloudflare Workers Rust 中使用异步代码（Future）
💡
原文中文，约8900字，阅读约需22分钟。
📝
内容提要
Cloudflare Workers 支持 Rust，通过 wasm_bindgen 将 Rust 编译为 wasm。由于 wasm 是单线程的，无法使用 tokio 工具。文章介绍了如何在 Cloudflare Workers 中使用 async/await 和 futures API 实现异步操作，包括使用 futures::join! 和 futures::future::join_all 来并行执行多个任务并限制并发数。
🎯
关键要点
- Cloudflare Workers 支持 Rust，通过 wasm_bindgen 将 Rust 编译为 wasm。
- 由于 wasm 是单线程的，无法使用 tokio 工具。
- Cloudflare Workers 提供了 Rust 开发的文档，但文档简略，缺乏详细的异步操作示例。
- Cloudflare Workers 提供一个异步执行环境，可以使用 async/await。
- 使用 futures::join! 可以并行执行多个任务并收集结果。
- 使用 futures::future::join_all 可以处理多个 future 的数组，但要求类型一致。
- 可以使用 futures::stream::iter 配合 buffer_unordered 来限制并发数。
- wasm_bindgen_futures::spawn_local 类似于 tokio 的 spawn，但有一些限制。
- spawn_local 传入的 Future 必须没有返回值，导致无法收集结果。
❓
延伸问答
如何在 Cloudflare Workers 中使用 Rust 进行异步编程？
可以使用 async/await 语法和 futures API 来实现异步编程，Cloudflare Workers 提供了一个异步执行环境。
为什么在 Cloudflare Workers 中无法使用 tokio？
因为 wasm 环境是单线程的，无法使用 tokio 及其工具方法，如 spawn。
如何在 Cloudflare Workers 中并行执行多个任务？
可以使用 futures::join! 来并行执行多个任务并收集结果。
futures::future::join_all 有什么限制？
使用 futures::future::join_all 时，所有 future 的类型必须一致，否则会报错。
如何限制并发数在 Cloudflare Workers 中？
可以使用 futures::stream::iter 配合 buffer_unordered 来限制并发数。
wasm_bindgen_futures::spawn_local 的作用是什么？
spawn_local 用于立即执行一个传入的 future，但要求该 future 的输出类型必须是 ()，无法收集结果。
➡️
