embassy/examples/nrf/src/bin/mutex.rs
Dario Nieuwenhuis 6731948056 Add async Mutex.
2022-04-06 01:39:58 +02:00

45 lines
1.1 KiB
Rust

#![no_std]
#![no_main]
#![feature(type_alias_impl_trait)]
use defmt::{info, unwrap};
use embassy::blocking_mutex::raw::ThreadModeRawMutex;
use embassy::executor::Spawner;
use embassy::mutex::Mutex;
use embassy::time::{Duration, Timer};
use embassy_nrf::Peripherals;
use defmt_rtt as _; // global logger
use panic_probe as _;
static MUTEX: Mutex<ThreadModeRawMutex, u32> = Mutex::new(0);
#[embassy::task]
async fn my_task() {
loop {
{
let mut m = MUTEX.lock().await;
info!("start long operation");
*m += 1000;
// Hold the mutex for a long time.
Timer::after(Duration::from_secs(1)).await;
info!("end long operation: count = {}", *m);
}
Timer::after(Duration::from_secs(1)).await;
}
}
#[embassy::main]
async fn main(spawner: Spawner, _p: Peripherals) {
unwrap!(spawner.spawn(my_task()));
loop {
Timer::after(Duration::from_millis(300)).await;
let mut m = MUTEX.lock().await;
*m += 1;
info!("short operation: count = {}", *m);
}
}