【tokio】异步编程

同步编程和异步编程的区别

同步编程：按程序编写的顺序执行，如果操作不能立即获得执行结果，会一直阻塞直到获取到结果。

异步编程：如果操作不能立即获得执行结果，操作会挂起到后台，执行线程不阻塞，继续执行其他操作任务。一旦操作完成，操作恢复，从中断的地方继续执行。

Rust异步编程

rust异步编程使用async和await关键字。

async：标识函数为异步, async标识的函数会编译成异步执行例程。

await：对返回值执行await时，才执行异步操作。这里的返回值是指调用异步函数的返回值，该返回值标识这个异步操作。

例子

async fn say_world() {
    println!("world");
}

#[tokio::main]
async fn main() {
    // Calling `say_world()` does not execute the body of `say_world()`.
    let op = say_world();

    // This println! comes first
    println!("hello");

    // Calling `.await` on `op` starts executing `say_world`.
    op.await;
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

输出

hello
world
1
2

有3点需要重点理解

1. 调用异步函数不会返回异步函数的执行结果，而是返回一个值代表这个异步函数。如上面例子op代表的就是async fn say_world()。
2. rust异步是惰性的，并不是在调用的时候执行，是在返回值调用.await时才执行，上面例子的输出也证实了这点。
3. 异步函数必须由运行时执行。运行时包含异步任务调度程序，提供事件I/O、计时器等。运行时不会自动启动，因此主函数需要启动它。下面会提到。

异步main函数

#[tokio::main]
async fn main() {
    println!("hello");
}
1
2
3
4

相比正常main函数有2点不同：

1. 增加了async
2. 增加了注释 #[tokio::main]

#[tokio::main]

这是一个注释宏，会将异步main函数转换为同步main函数，初始化运行时，并执行异步main函数。

#[tokio::main]
async fn main() {
    println!("hello");
}
1
2
3
4

转化为

fn main() {
    let mut rt = tokio::runtime::Runtime::new().unwrap();
    rt.block_on(async {
        println!("hello");
    })
}
1
2
3
4
5
6