一文读懂Rust的async

时间  2021-03-06 标签 web 编程 多线程 并发 app 框架 异步 async 编程语言 ide

一文读懂Rust的async

不一样的编程语言表现异步编程的方式可能不同，Rust跟JavaScript的async/await相似：使用的关键字啊，编程模型啊都差很少啦! 也有些不同的地方，毕竟Rust是从新设计的语言嘛，好比：在JavaScript中使用Promise表示须要延迟异步执行的计算,在Rust中使用的是Future.在JavaScript中不须要选择指定运行异步代码的运行时，在Rust中须要. Rust还更麻烦了？还得选择指定运行时?web

这是由于Rust是能够面向硬件、嵌入式设备的操做系统级别的编程语言就像C++，而且零抽象成本.这就须要Rust须要有选择地把功能包含进标准库里.简单来讲，为了知足不一样的编程场景Rust标准库就没有包含指定异步代码运行时，咱们能够根据具体的场景选择不一样的运行时。编程

是否是感受还有点晕乎？不要紧，下面咱们会介绍怎么在Rust中编写异步（async）代码.知道了怎么编写异步代码，也就知道async是什么了.若是你是第一次使用Rust编写异步代码或者第一次使用异步代码库正在迷茫从何入手，那恭喜你，这篇文档特别适合你.开始以前咱们先快速的介绍下异步编程的基本要素.多线程

基本要素

编写异步的应用，至少须要俩个crate:并发

  1. futures:这个是Rust官方团队提供维护的crate.
  2. 异步代码运行时crate: 能够本身选择，好比：Tokio, async_std, smol等等.

你可能不想在项目中引入过多依赖，但这些依赖就像chrono和log是比较基础的依赖.惟一的不一样是这些依赖是面向异步编程的.app

咱们接下来会使用Tokio作为运行时，刚开始你最好也先了解熟悉使用一种运行时，而后再尝试使用其它运行时。框架

由于这些运行时之间有不少相通的地方，熟悉了一个再去熟悉其它的就简单了。就像咱们学习编程语言同样，学好学深一门编程语言，再去学习其它的语言就快了。不要一开始就几门语言一块儿学，这样极可能实际开发时这也不行那也不行换来换去仍是不能开发出东西.异步

咱们能够像下面这样引入依赖：async

[dependencies]
futures = { version = "0.3.*" }
tokio = {version = "0.2.*", features = ["full"] }123

在main.rs中敲入如下代码:编程语言

use futures::prelude::*;
use tokio::prelude::*;

fn main() {
    todo!();
}123456

能够执行下cargo check若是没什么报错信息，依赖配置就完成了.接下来咱们介绍怎么使用运行时。ide

运行时

像咱们先前说的Rust标准库并无指定异步代码的运行时，因此咱们本身选择运行时并配置相应的依赖。这里咱们选择了使用Tokio:

tokio = {version = “0.2.*”, features = [“full”] }

有些第三方库可能须要咱们使用指定的异步代码运行时,由于它们内部是对特定运行时库进行了封装。好比：web开发框架actix_web就是基于tokio封装开发的.但大多少状况咱们均可以本身选择运行时。不管咱们选择那一种运行时，在开始编写代码前都须要先搞清除：

  1. 怎么启动运行时？
  2. 怎么生成 Future ？
  3. 怎么处理阻塞(IO密集)和CPU密集任务？

搞清除了这三个问题基本上也就学会怎么编写异步代码了.接下来咱们就以tokio为例演示下:

  1. 启动运行时

    能够实例化一个运行时，并派生一个Future指定给运行时。这个Future就是异步代码的主入口，能够把它想象成异步代码的main函数:

    async fn app() {
    todo!()
}

fn main() {
    let mut rt = tokio::runtime::Runtime::new().unwrap();
    let future = app();
    rt.block_on(future);
}

    还可使用宏，简化代码为：

    #[tokio::main]
async fn main() {

}

    虽然代码行数少了，功能跟上面的代码仍是同样的哦!

  • 1
  • 2
  • 3
  • 4
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9

为运行时生成Future

你想并发运行多个任务时，就能够像这样生成Future：

use tokio::task;

async fn our_async_program() {
    todo!();
}

async fn app() {
    let concurrent_future = task::spawn(our_async_program());
    todo!()
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10

处理阻塞和CPU密集性任务

什么是阻塞性的任务?什么是CPU密集性的任务呢?能够简单的理解为这两种任务都会长时间的霸占CPU阻塞线程继续执行其它任务.就比如工地上有个包工头专门负责分配任务给小工门干，有些小活小任务包工头可能顺手就干了，可是一些耗时比较长的好比去搬一车砖头，包工头就不能本身去干了，由于它去搬砖头了就没人负责任务分配了，小工们活都干完了只能等着包工头分配任务才能继续干活.包工头呢?还在搬砖头呢.显然这是会影响总体工做效率的。代码也同样，要有个专门负责整体分配任务的线程，在这个线程中就不能再执行其它比较耗费时间的的任务了。那耗费时间的任务谁来执行呢?小工呗，也就是派生新的Future. 就像这个样子：

use tokio::task;

fn fib_cpu_intensive(n: u32) -> u32 {
    match n {
        0 => 0,
        1 => 1,
        n => fib_cpu_intensive(n - 1) + fib_cpu_intensive(n - 2),
    }
}

async fn app() {
    let threadpool_future = task::spawn_blocking(||fib_cpu_intensive(30));
    todo!()
}

tokio是使用的spawn_blocking去派生新的Future使用新的线程执行比较耗时的任务，其它运行时库可能API不同但也会提供相似的方法.

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14

异步开发样例

支持咱们已经学习了怎么使用Rust编写异步代码，接下来把所学内容整合到一块儿作个样例:

use futures::prelude::*;
use tokio::prelude::*;
use tokio::task;
use log::*;

// Just a generic Result type to ease error handling for us. Errors in multithreaded
// async contexts needs some extra restrictions
type Result<T> = std::result::Result<T, Box<dyn std::error::Error + Send + Sync>>;

async fn app() -> Result<()> {
    // I treat this as the `main` function of the async part of our program. 
    todo!()
}

fn main() {
    env_logger::init();
    let mut rt = tokio::runtime::Runtime::new().unwrap();

    match rt.block_on(app()) {
        Ok(_) => info!("Done"),
        Err(e) => error!("An error ocurred: {}", e),
    };
}1234567891011121314151617181920212223

使用到的crate有:

  • 提供异步代码运行时的 tokio
  • Rust日志门面log
  • 日志工具env_logger

Cargo.toml相似这个样子：

[dependencies]
futures = { version = "0.3.*"}
tokio = {version = "0.2.*", features = ["full"] }
log = "0.4.*"
env_logger = "0.7.*"12345

须要注意的是env_logger须要根据环境变量RUST_LOG设置日志级别

基本上全部的异步编程项目均可以使用相似这样的依赖配置和main.rs.根据不一样的使用场景还能够优化下错误处理和日志.好比能够考虑使用 Anyhow处理错误，能够考虑使用 async-log更好的在异步多线程环境中输出日志.在本文档中接下来的代码就基于这个样例模板开发了。

异步函数

在Rust中编写异步函数跟先前编写普通函数有点不同.先前接触Rust函数时，你可能已经注意到函数的参数返回值都须要声明确切的类型。异步函数的返回值都是通过Future包装的。若是你读了关于Future的文档，按照这个思路你可能认为应该像下面这样编写异步函数:

async fn our_async_program() -> impl Future<Output = Result<String>> {
    future::ok("Hello world".to_string()).await
}123

不用这么麻烦，比较Rust是从新设计的语言.当你使用async关键字时，Rust会自动的使用Future封装返回只，因此你原来怎么给普通函数定义返回值就继续那么地干，就像这个样子：

async fn our_async_program() -> Result<String> {
    future::ok("Hello world".to_string()).await
}123

这里使用的future::ok是future库提供的方便咱们开发使用的，用于生成状态为ready的future.

你可能会见到使用异步代码块async {...}建立异步代码的，这是为了更灵活的定义返回值类型，不过大多少状况下使用异步函数就够了.接下来咱们编写一个使用异步函数的例子.

建立Web请求

在Rust中future是lazy(懒)的.也就是说，默认状况下当你建立了一个future，它是什么都不干的，非得等你调用await告诉它该干活了，它才开始干活.

接下来咱们以发起处理Web请求的场景用代码演示一会儿：

fn slowwly(delay_ms: u32) -> reqwest::Url {
    let url = format!(
    "http://slowwly.robertomurray.co.uk/delay/{}/url/http://www.google.co.uk", 
    delay_ms,
    );
    reqwest::Url::parse(&url).unwrap()
}

async fn app() -> Result<()> {
    info!("Starting program!");
    let _resp1 = reqwest::get(slowwly(1000)).await?;
    info!("Got response 1");
    let _resp2 = reqwest::get(slowwly(1000)).await?;
    info!("Got response 2");
    Ok(())
}12345678910111213141516

建立web请求使用到了reqwest库，须要把这个库添加到Cargo.toml的依赖区域:

reqwest = “0.10.*”

执行上面的代码输出相似这个样子：

1.264 [INFO] - Got response 1
2.467 [INFO] - Got response 2
2.468 [INFO] - Done123

这里的日志格式是自定义的，前面的数字是程序执行的时间，自定义日志格式的代码是这个样子地：

et start = std::time::Instant::now();
env_logger::Builder::from_default_env().format(move |buf, rec| {
    let t = start.elapsed().as_secs_f32();
    writeln!(buf, "{:.03} [{}] - {}", t, rec.level(),rec.args())
}).init();12345

从日志输出能够看出，咱们的函数并非一块儿执行的，而是一个执行完成后另外一个才开始执行的，由于咱们这里仍是使用的普通函数并无使用异步函数.接下来是修改成异步函数的版本：

async fn request(n: usize) -> Result<()> {
    reqwest::get(slowwly(1000)).await?;
    info!("Got response {}", n);
    Ok(())
}

async fn app() -> Result<()> {
    let resp1 = task::spawn(request(1));
    let resp2 = task::spawn(request(2));

    let _ = resp1.await??;
    let _ = resp2.await??;

    Ok(())
}123456789101112131415

tokio提供的spawn函数可让咱们使用多线程并发执行异步函数.

执行的效果相似这个样子：

1.247 [INFO] - Got response 2
1.256 [INFO] - Got response 1
1.257 [INFO] - Done123

能够跟上面使用普通函数的方式对比一会儿，是否是整体效率快多了，俩个请求不须要互相等待，各自说干就干，就是这么快.

补充

何时该派生Future执行任务呢？这里有几条建议

  1. 优先选用没有阻塞的操做库.
  2. 若是不肯定就派生一个吧.

学员专享pdf版本请点这里下载

参考原文

联系我们 沪ICP备13005482号-10