Demo for parallel futures in Rust

jesty_concurrent.rs

use std::time::Duration;

use async_std::sync::Mutex;

struct Foo(pub u64);

impl Foo {
    pub async fn bar(&mut self) {
        let my_mutex = Mutex::new(self);
        futures::future::join(
            async {
                for _ in 0..100 {
                    my_mutex.lock().await.0 += 1;
                    tokio::time::sleep(Duration::from_nanos(1)).await
                }
            },
            async {
                for _ in 0..100 {
                    my_mutex.lock().await.0 += 1;
                    tokio::time::sleep(Duration::from_nanos(1)).await
                }
            }
        ).await;
    }
}

#[tokio::main]
async fn main() {
    let mut foo = Foo(1);
    foo.bar().await;
    println!("Hello, {}!", foo.0);
}

udate: apparently if you use the join function rather than the join! macro rust-analyzer won't be effectively disabled inside the async blocks