Rust：tokio可以被理解为类似于Javascripts事件循环还是像它一样使用？

Question

我不确定tokio是否类似于Javascript中的事件循环，也是一个非阻塞运行时，或者它是否可以用类似的方式工作。在我的理解中，tokio是Rust中期货的运行时。因此它必须实现某种用户区线程或任务，这可以通过事件循环（至少部分）来实现，以安排新任务。

让我们使用以下Javascript代码：

console.log('hello1');
setTimeout(() => console.log('hello2'), 0);
console.log('hello3');
setTimeout(() => console.log('hello4'), 0);
console.log('hello5');

输出将为

hello1
hello3
hello5
hello2
hello4

如何在tokio中执行此操作？Tokio是否意味着整体上像这样工作？我尝试了以下代码

async fn set_timeout(f: impl Fn(), ms: u64) {
    tokio::time::sleep(tokio::time::Duration::from_millis(ms)).await;
    f()
}

#[tokio::main]
async fn main() {
    println!("hello1");
    tokio::spawn(async {set_timeout(|| println!("hello2"), 0)}).await;
    println!("hello3");
    tokio::spawn(async {set_timeout(|| println!("hello4"), 0)}).await;
    println!("hello5");
}

输出正好

hello1
hello3
hello5

如果我将代码更改为

    println!("hello1");
    tokio::spawn(async {set_timeout(|| println!("hello2"), 0)}.await).await;
    println!("hello3");
    tokio::spawn(async {set_timeout(|| println!("hello4"), 0)}.await).await;
    println!("hello5");

输出是

hello1
hello2
hello3
hello4
hello5

但是我不明白整个async/wait/Future功能的重点，因为我的“async”set_timeout任务实际上是阻塞了其他println语句...

Answer 1

与JavaScript不同，Rust不会启动异步函数的执行，直到等待未来。意思是< code>set_timeout(|| println！(“hello2”)，0)只创造新的未来。它根本不执行它。当你等待它的时候，它才会被执行。<代码>。await实质上阻塞了当前线程，直到未来线程完成，这不是“真正的异步应用程序”。要让你的代码像JavaScript一样并发，可以使用< code>join！宏:-

use tokio::join;
use tokio::time::*;

async fn set_timeout(f: impl Fn(), ms: u64) {
    sleep(Duration::from_millis(ms)).await;
    f()
}

#[tokio::main]
async fn main() {
    println!("hello1");
    let fut_1 = tokio::spawn(set_timeout(|| println!("hello2"), 0));
    println!("hello3");
    let fut_2 = tokio::spawn(set_timeout(|| println!("hello4"), 0));
    println!("hello5");

    join!(fut_1, fut_2);
}

如果您想了解< code>Promise.all，可以使用FuturesOrdered。

更多信息：-

• https://news.ycombinator.com/item?id=21473777
• https://rust-lang.github.io/async-book/06_multiple_futures/01_chapter.html

Answer 2

简而言之：是的，Tokio的工作方式与JavaScript事件循环非常相似。但是，您的第一个片段有三个问题。

首先，它在等待事情发生之前从main（）返回。与 JavaScript 代码不同，JavaScript 代码可能在浏览器中运行，即使在您在控制台中键入的代码完成运行后也会运行超时，Rust 代码位于一个短暂的可执行文件中，该可执行文件在 main（） 之后终止。如果可执行文件停止运行，则计划稍后发生的任何事情都不会发生，因为它从main（）返回。

第二个问题是调用set_timeout（）异步函数的匿名异步块对其返回值没有任何作用。Rust和JavaScript中的异步函数之间的一个重要区别是，在Rust中，您不能只调用异步函数就完成了它。在JavaScript中，异步函数返回一个promise，如果您不等待该promise，事件循环仍将在后台执行异步函数的代码。在Rust中，异步函数返回一个future，但它与任何事件循环都没有关联，它只是为运行它做准备。然后，您需要使用等待它。等待（与JavaScript中的含义相同）或显式地将其传递给tokio:：spawn（）以在后台执行（与调用相同，但不等待JavaScript中的函数）。异步块两者都不做，因此调用＜code＞set_timeout（）＜/code＞是不可行的。

最后，代码立即等待 spawn（） 创建的任务，这首先违背了调用 spawn（） 的目的 - tokio：：spawn（foo（））.await 在功能上等同于 foo（）.await for any foo（））。

第一个问题可以通过在main的末尾添加一个小睡眠来解决。（这不是正确的修复，但可以用来演示发生了什么。）第二个问题可以通过删除异步块并将＜code＞set_timeout（）来解决。第三个问题通过删除不必要的来解决。等待任务的。

#[tokio::main]
async fn main() {
    println!("hello1");
    tokio::spawn(set_timeout(|| println!("hello2"), 0));
    println!("hello3");
    tokio::spawn(set_timeout(|| println!("hello4"), 0));
    println!("hello5");
    tokio::time::sleep(tokio::time::Duration::from_millis(1)).await;
}

此代码将打印“预期”1，3，5，4，2（尽管在此类程序中不能保证顺序）。真正的代码不会以睡眠结束;相反，它将等待它创建的任务，如Shivam的答案所示。