Rust 中的 await

Rust 3月前 41

在本文中，我们将学习 Rust 中 await 的含义。

Rust 中的 `await`

async-await 是一种编写函数的技术，可以暂停、将控制权交给运行时，然后从中断的地方继续执行。通常，这些暂停用于等待 I/O，但它们可以用于各种目的。

async-await 可能对 JavaScript 或 C# 很熟悉。然而，Rust 的功能实现有一些重要的变化。

要使用 async-await，你必须将 fn 替换为 async fn：

asyncfn new_fxn()-> u32 {..}

与传统函数相比，调用 async fn 不会立即生效。相反，它返回一个 future。

计算暂停并等待执行。使用 .await 运算符执行 future：

asyncfn second_fxn(){letfuture=new_fxn();letresult: u32 =future.await;...}

这个例子说明了 Rust 和其他语言的第一个区别：我们写 future.await 而不是 await future。这种语法与 Rust 的 ? 更好地交互。用于传播错误的运算符，这在 I/O 中很常见。

你可以写 future.await? 承担过错，等待很多的结果。此外，它还具有使链接方法无痛的好处。

await 一词只能在异步函数的上下文中使用，并且只能等待异步函数。

Rust 的 futures 是宽松的；默认情况下，在进行第一次轮询之前，它们将不做。当你等待这个未来时，它就会被调查。

例如，如果你调用一个函数，该函数在程序开始时返回 future，但直到程序结束才等待它，则在你等待它之前不会执行实际请求。

例子：

usestd::thread;usetokio::time::{sleep,Duration};usefutures::future;#[tokio::main]asyncfn main(){letmutawait_demo=Vec::new();forcountin1..=5{await_demo.push(tokio::spawn(asyncmove{println!("Start the thread {count}, id= {:?}",thread::current().id());sleep(Duration::from_millis(5000)).await;println!("end the thread {count}, id = {:?})",thread::current().id());}));}future::join_all(await_demo).await;}

首先，创建五个 futures（五个 async 块），每个 future 创建一个 sleep future 并在其上调用 await。这些未来同时存在。

每个块显示 await 之前和之后的线程 ID。

输出：

Standard Output
Start the thread 1, id= ThreadId(2)
Start the thread 3, id= ThreadId(2)
Start the thread 4, id= ThreadId(2)
Start the thread 5, id= ThreadId(2)
Start the thread 2, id= ThreadId(3)
end the thread 2, id = ThreadId(2))
end the thread 3, id = ThreadId(3))
end the thread 1, id = ThreadId(3))
end the thread 4, id = ThreadId(3))
end the thread 5, id = ThreadId(3))

声明：本站所有文章，如无特殊说明或标注，均为本站原创发布，任何个人或组织，在未征得本站同意时，禁止复制、盗用、采集、发布本站内容到任何网站。本站所有源码与软件均为原作者提供，仅供学习和研究使用。如您对本站的相关版权有任何异议，或者认为侵犯了您的合法权益，请及时通知我们处理。

Rust

Rust 中的 await

相关文章

Rust 中的 `await`