mirror of
https://github.com/rtic-rs/rtic.git
synced 2024-11-24 04:32:52 +01:00
50 lines
1.2 KiB
Text
50 lines
1.2 KiB
Text
//! examples/lock-free.rs
|
|
|
|
#![deny(unsafe_code)]
|
|
#![deny(warnings)]
|
|
#![no_main]
|
|
#![no_std]
|
|
#![feature(type_alias_impl_trait)]
|
|
|
|
use panic_semihosting as _;
|
|
|
|
#[rtic::app(device = lm3s6965, dispatchers = [GPIOA])]
|
|
mod app {
|
|
use cortex_m_semihosting::{debug, hprintln};
|
|
|
|
#[shared]
|
|
struct Shared {
|
|
#[lock_free] // <- lock-free shared resource
|
|
counter: u64,
|
|
}
|
|
|
|
#[local]
|
|
struct Local {}
|
|
|
|
#[init]
|
|
fn init(_: init::Context) -> (Shared, Local) {
|
|
foo::spawn().unwrap();
|
|
|
|
(Shared { counter: 0 }, Local {})
|
|
}
|
|
|
|
#[task(shared = [counter])] // <- same priority
|
|
async fn foo(c: foo::Context) {
|
|
bar::spawn().unwrap();
|
|
|
|
*c.shared.counter += 1; // <- no lock API required
|
|
let counter = *c.shared.counter;
|
|
hprintln!(" foo = {}", counter).unwrap();
|
|
}
|
|
|
|
#[task(shared = [counter])] // <- same priority
|
|
async fn bar(c: bar::Context) {
|
|
foo::spawn().unwrap();
|
|
|
|
*c.shared.counter += 1; // <- no lock API required
|
|
let counter = *c.shared.counter;
|
|
hprintln!(" bar = {}", counter).unwrap();
|
|
|
|
debug::exit(debug::EXIT_SUCCESS); // Exit QEMU simulator
|
|
}
|
|
}
|