advance/async/getting-started

[giscus[bot]]

advance/async/getting-started

https://course.rs/advance/async/getting-started.html

[fengbianyun]

CPU 密集的任务很可能会一直霸着着【修改为：霸占着】 CPU。

[Jamesinit]

感觉同时载歌载舞这个例子并没用很好的体现出异步来。
他的执行结果还是顺序的啊。
我尝试在各个函数加打印，发现还是顺序执行的。
在sing_song之前加sleep，也并没有先执行dance，有点迷惑。
我理解是当sing这个sleep，另一个dance不应该先执行，这样才是同时载歌载舞吗？

[duanyuluo]

async_std::sleep返回的也是一个Future，所以，这个函数并不是挂起当前线程，而是切换到其他Future执行了，比如这个例子中的dance。

[QIN2DIM]

你需要加点特技

[dependencies]
tokio = { version = "1", features = ["full"] }

use std::time::Duration;
use tokio::time::sleep;

struct Song {
    author: String,
    name: String,
}

async fn learn_song() -> Song {
    Song {
        author: "坤坤".to_string(),
        name: String::from("《JntM》"),
    }
}

async fn sing_song(song: Song) {
    println!(
        "唱一首，{}的 {} ~ {}",
        song.author, song.name, "music"
    );
}

async fn dance() {
    println!("跳");
}

async fn learn_and_sing() {
    let song = learn_song().await;
    sleep(Duration::from_secs_f32(0.000001)).await;
    sing_song(song).await;
}

#[tokio::main]
async fn main() {
    let f1 = learn_and_sing();
    let f2 = dance();
    futures::join!(f1, f2);
}

[zhenxingliu]

结合了一下下面的打印线程ID例子,这些个Future是在同一个线程执行,就是一个M:N的模型.

[suningzh]

你好像少了一个Rap

[jockchou]

这里的异步是在单线程（Main线程）上做异步，你用Thread.sleep是整个Main线程都阻塞挂起了。
异步是指Main线程上有2个IO操作耗时，async异步函数会创建2个Futuer，这2个Futuer任何一个执行不会阻塞别一个。

[MrZLeo]

而且 Rust 也不允许你在特征中声明 async 函数(可以通过三方库实现)

[MrZLeo]

现在的Rust支持在特征中声明async函数了！

[kingwingfly]

曲婉婷的例子可以改一改，毕竟有争议（滑稽

[Rgoogle]

这个例子不好说明，应该异步要体现出顺序不一致

[sunface]

现在貌似是周杰伦 🤣

[lieren1922]

就是，这个例子加上一个sleep就比较好，参见上面的 QIN2DIM 例子。

[iscas-zac]

第一部分的

OS 线程

和

多线程

建议统一一下，用同一个术语来指代

[PPhoss]

菜鸟提问：block_on( ) 阻塞当前线程的意思是 会创建一个新的线程来运行future吗？

[kingwingfly]

不会，都是在同一个Runtime里面。

[bxb100]

我就是回来提醒你们 rust 即将支持 async trait 意味着将可以在堆中存放异步状态

[DAIMENGEN]

个人理解如下：

首先，future并不是多线程。

Rust多线程编程的情况如下：

线程 （通过 thread::spawn 创建的） CUP
语言线程A -------------> OS线程1
语言线程B -------------> OS线程2
语言线程C -------------> OS线程3
语言线程D -------------> OS线程4

备注：一旦语言线程通过 thread::sleep 方法被阻塞，说明 OS 线程被阻塞。

anync await 编程

future_A -------> 语言线程A -------> OS线程1
future_B -------> 语言线程A -------> OS线程1
future_C -------> 语言线程A -------> OS线程1
future_D -------> 语言线程A -------> OS线程1

备注：调用 future_A 的 await 方法并不会阻塞语言线程A，此时的语言线程A还可以继续执行 future_B,C,D.。

猜测：如果，语言线程A里面的 所有 futrue 都处于 await 状态，语言线程A应该是处于了阻塞状态，也是会产生线程的上下文切换的。关于这个问题，还在研究中。

[guqihao-7]

你好，请问 future 是否就类似于协程？Rust 线程（您提到的语言线程）切换 future 是否就相当于协程切换，整个过程中无上下文切换？

[TsGanT]

我有一个例子，可能可以更简单的说明一个线程中运行多个future（task）的case：(交替打印结果，await阻塞当前task但不阻塞线程；)

[dependencies]
futures = "0.3"
[dependencies.async-std]
version = "1.7.0"
features = ["attributes"]

use core::time;
use std::time::Duration;

use async_std::task;
use futures::{executor::block_on, join};

async fn hello_world() {
    for j in 0..10 {
        task::sleep(time::Duration::from_secs(3)).await;
        println!("hello, world!: {:?}", j);
    }
}

async fn hello_cat() {
    for i in 0..10 {
        task::sleep(Duration::new(1, 0)).await;
        println!("hello, kitty! : {:?}", i);   
    }
}

async fn async_main() {
    let future1 = hello_world();
    let future2 = hello_cat();
    join!(future1, future2);
}

fn main() {
    let f = async_main();
    block_on(f);
}

[liushichuan]

[package]
name = "async_exp"
version = "0.1.0"
edition = "2021"

# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html

[dependencies]
async-std = "1.12.0"
futures = "0.3"

use std::time;

use futures::executor::block_on;

fn main() {
    block_on(test())
}

async fn sing() {
    async_std::task::sleep(time::Duration::from_secs(1)).await;
    println!("sing! {:?}", std::thread::current().id());
}

async fn dance() {
    println!("dance! {:?}", std::thread::current().id())
}

async fn test() {
    let sing = sing();
    let dance = dance();

    futures::join!(sing, dance);
}

可以打印一下线程id

[TsGanT]

这一章翻来覆去看了三遍，我怎么感觉最后真正实现并发的，是join啊！其他的什么async await其实就起到一个标记作用，更多的可能是给编译器看的，表示这部分代码 可以 被并发的执行；但是真正去实现并发的还是join！，因为他可以同时等待多个异步任务。其他那些等待单个异步任务完成的选手，那执行起来就还是有点像同步。。。

[TableBear]

join! 宏只是等待Future执行完成而已，并没有实现并发。async await 确实是一个标记作用，编译器会将对应函数和函数调用封装成Future，然后交给async 运行时去调度执行，这才是真正开始了并发。你说的其他等待单个异步任务的应该是block_on和await。block_on在文章中确实是会让Future同步，但是await则不同两个不同Future中的await 实际上还是可能异步执行的。以上是个人见解

[tsingroo]

很像go里面的goroutine协程实现，底层跟线程也是M:N对应。并且在新版本对调度进行优化，不会产生让协程饿死的情况

[tsingroo]

从语法和使用上来看，几乎和javascript的async/await语法一样

[vince-1998]

因此.await对于实现异步编程至关重要，它允许我们在同一个线程内并发的运行多个任务。
这句话太关键了，有时候不注意看会走很多弯路。。。。。

[vince-1998]

https://blog.csdn.net/vince1998/article/details/138422536?spm=1001.2014.3001.5501 大家可以看看我写的博客，对作者代码进行了进一步的详细解释

[guqihao-7]

这么读下来，感觉 async 标记的代码块就是协程啊，多对一映射到一个 Rust 线程，Rust 线程和 OS 线程又是 1：1。同时因为 async 标记的语法块会被转换成实现了Future特征的状态机，async 代码块切换感觉就是协程切换而不是线程上下文切换，所以性能高点。
不知道上述理解是否有误，烦请指正。

[TableBear]

我觉得没毛病👍

[YdayangY]

async为什么不会引起线程上下文切换？我理解的是，如果线程A的cpu时间片用完了，线程B开始执行就会导致线程切换。

[TableBear]

async 的task之间切换不是线程之间切换，它是用户线程主动切换task去执行，这样自然不会引起线程上下文切换。你可以理解为一个线程本来在执行A任务，A卡住了，然后去执行B任务。

[YdayangY]

明白了，谢谢。