在“等待”点上使用“std::sync::Mutex”是否总是导致死锁?

虽然我已经阅读了所有的OP,但的答案和评论 Why do I get a deadlock when using Tokio with a std::sync::Mutex? ,我还不明白为什么OP中的代码会永远阻塞。

以下是原始代码的略微更改版本:

use std::sync::Arc;
use std::sync::Mutex;
// use tokio::sync::Mutex;
use tokio::time::Duration;

async fn f(mtx: Arc<Mutex<i32>>, index: usize) {
    println!("{}: trying to lock...", index);
    {
        let mut v = mtx.lock().unwrap();
        // let mut v = mtx.lock().await;
        println!("{}: locked", index);
        tokio::time::sleep(Duration::from_millis(1)).await;
        *v += 1;
    }
    println!("{}: unlocked", index);
}

#[tokio::main]
async fn main() {
    let mtx = Arc::new(Mutex::new(0));
    tokio::join!(f(mtx.clone(), 1), f(mtx.clone(), 2));
}

输出为

1: trying to lock...
1: locked
2: trying to lock...

(and blocks forever...)

根据答案和评论(如果我没有看错的话),原因是 整个代码在单线程环境中执行 。如果 斜体的 部分是真的,我可以理解阻塞行为。然而,我不明白 斜体的 第一部分实际上是正确的。

据我所知,

• Tokio的默认运行时是多线程的,除非您明确指定 #[tokio::main(flavor = "current_thread")] ( source )

• 和 await ed任务 可以 自动移动到另一个工作线程( source ).

因此,我认为如果任务(即。 f(mtx.clone(), 1).await , f(mtx.clone(), 2).await 和 sleep(...).await 是 被选中的 (由Tokio运行时)在不同的线程中执行,但代码 看 作为运行时进行阻塞 发生 选择所有任务都在同一个线程中执行。

我的理解正确吗?