Rust 的异步编程模型是基于 async 和 await 关键字的。这些关键字允许你编写看起来像是同步代码的异步代码，同时保持高效的并发性能。
为什么需要异步编程？
在处理 I/O 操作（如网络请求、文件读写等）时，传统的同步方法可能会导致程序阻塞，从而降低效率。通过使用异步编程技术，我们可以避免这种阻塞，并提高应用程序的响应速度和资源利用率。
示例：简单的异步函数
下面是一个使用 Rust 编写的简单异步函数示例：
-- -------------------- ---- -------
--- --------------------
--- --------------
--- -------------------- ------
--- ------------
-- --------
----- -- ---------------- -
------------------------
----------------------------------------------------- -- ----------
--------------------
-
--------------
----- -- ------ -
-----------------------
-在这个例子中，async_function 是一个异步函数，它会休眠两秒钟。这个过程不会阻塞主线程，而是允许其他操作继续执行。
异步上下文
在 Rust 中，异步函数返回的是一个实现了 Future trait 的类型。这个 trait 提供了一个 poll 方法，用于检查异步操作是否已经完成。为了有效地利用异步功能，你需要使用异步运行时（runtime），比如 Tokio 或者 Smol。
示例：使用 Tokio 运行异步代码
Tokio 是一个流行的异步运行时，它提供了丰富的库来支持异步 I/O 操作。以下是如何使用 Tokio 来运行异步代码的示例：
-- -------------------- ---- -------
--- ------------
----- -- ------------ -
----------------------
------------------------------------------------
--------------------
-
--------------
----- -- ------ -
-------------------
-在这个例子中，我们使用了 Tokio 的 time::sleep 函数来模拟一个耗时的异步操作。
使用 async 和 await 关键字
async 关键字用于定义一个异步函数，而 await 关键字则用于等待一个实现了 Future trait 的对象完成。
示例：使用 await 关键字
-- -------------------- ---- -------
--- --------------------
--- ------------
----- -- ------------------- -- ------ -
------------------------------------------
-------------------
-
--------------
----- -- ------ -
--- ------ - --------------------------
-------------- --------
-在这个例子中，long_running_task 函数会休眠三秒钟，然后返回一个字符串。await 关键字用于等待该函数完成并获取结果。
异步流（Streams）
除了普通的异步函数外，Rust 还支持异步流（Streams）。异步流是一种特殊的异步对象，它可以按需生成数据。这在处理实时数据流（如网络流）时非常有用。
示例：创建和使用异步流
-- -------------------- ---- -------
--- ----------------------- -----------
----- -- --------------- -- ---- -------------------- - ---- -
-------------------- -- -- -- ---
-
--------------
----- -- ------ -
--- --- ------ - ----------------------
----- --- ---------- - ------------------- -
--------------- ---- ------
-
-在这个例子中，我们创建了一个异步流 create_stream，它按顺序生成数字 1 到 5。然后我们使用 while let 循环从流中逐个取出这些值。
错误处理
在异步代码中处理错误与同步代码类似，但有一些细微的差别。通常，我们会使用 Result 类型来表示可能发生的错误，并且需要将错误适配到异步上下文中。
示例：处理异步错误
-- -------------------- ---- -------
--- ------------
--- ------------------
----- -- ------------ -- ---------- ------- ------- -
------------------------------------------------
-- ---- -
-----------------
- ---- -
------
-
-
--------------
----- -- ------ -- ---------- ------- ------- -
--------------------
------
-在这个例子中，risky_task 函数可能会失败并返回一个错误。我们使用 ? 操作符来传播错误。
总结
本章介绍了 Rust 中的异步编程基础，包括异步函数、异步上下文、使用 async 和 await 关键字，以及异步流和错误处理。理解这些概念对于编写高效、响应迅速的 Rust 应用程序至关重要。通过结合使用 Tokio 等异步运行时，你可以充分利用 Rust 的异步能力来构建高性能的应用程序。