mirror of
https://github.com/rtic-rs/rtic.git
synced 2024-11-27 14:04:56 +01:00
multilock relock workaround
This commit is contained in:
parent
0779bbbe95
commit
0722bf8d15
2 changed files with 158 additions and 0 deletions
79
examples/multilock_problem.rs
Normal file
79
examples/multilock_problem.rs
Normal file
|
@ -0,0 +1,79 @@
|
|||
//! examples/multilock_vs_lockall.rs
|
||||
|
||||
#![deny(unsafe_code)]
|
||||
#![deny(warnings)]
|
||||
#![no_main]
|
||||
#![no_std]
|
||||
|
||||
use panic_semihosting as _;
|
||||
|
||||
#[rtic::app(device = lm3s6965, dispatchers = [GPIOA])]
|
||||
mod app {
|
||||
use cortex_m_semihosting::{debug, hprintln};
|
||||
|
||||
#[shared]
|
||||
struct Shared {
|
||||
shared1: u32,
|
||||
shared2: u32,
|
||||
shared3: u32,
|
||||
}
|
||||
|
||||
#[local]
|
||||
struct Local {}
|
||||
|
||||
#[init]
|
||||
fn init(_: init::Context) -> (Shared, Local, init::Monotonics) {
|
||||
locks::spawn().unwrap();
|
||||
|
||||
(
|
||||
Shared {
|
||||
shared1: 0,
|
||||
shared2: 0,
|
||||
shared3: 0,
|
||||
},
|
||||
Local {},
|
||||
init::Monotonics(),
|
||||
)
|
||||
}
|
||||
|
||||
// when omitted priority is assumed to be `1`
|
||||
#[task(shared = [shared1, shared2, shared3])]
|
||||
fn locks(c: locks::Context) {
|
||||
// nested multi-lock
|
||||
let s1 = c.shared.shared1;
|
||||
let s2 = c.shared.shared2;
|
||||
let s3 = c.shared.shared3;
|
||||
|
||||
(s1, s2, s3).lock(|s1, s2, s3| {
|
||||
*s1 += 1;
|
||||
*s2 += 2;
|
||||
*s3 += 3;
|
||||
|
||||
hprintln!("Multiple locks, s1: {}, s2: {}, s3: {}", s1, s2, s3).ok();
|
||||
});
|
||||
|
||||
// re-construct gives error (consumed by above lock)
|
||||
let s = locks::SharedResources {
|
||||
shared1: s1,
|
||||
shared2: s2,
|
||||
shared3: s3,
|
||||
};
|
||||
|
||||
// nested multi-lock destruct
|
||||
let locks::SharedResources {
|
||||
shared1,
|
||||
shared2,
|
||||
shared3,
|
||||
} = s;
|
||||
|
||||
(shared1, shared2, shared3).lock(|s1, s2, s3| {
|
||||
*s1 += 1;
|
||||
*s2 += 2;
|
||||
*s3 += 3;
|
||||
|
||||
hprintln!("Multiple locks, s1: {}, s2: {}, s3: {}", s1, s2, s3).ok();
|
||||
});
|
||||
|
||||
debug::exit(debug::EXIT_SUCCESS); // Exit QEMU simulator
|
||||
}
|
||||
}
|
79
examples/multilock_problem_workaround.rs
Normal file
79
examples/multilock_problem_workaround.rs
Normal file
|
@ -0,0 +1,79 @@
|
|||
//! examples/multilock_vs_lockall.rs
|
||||
|
||||
#![deny(unsafe_code)]
|
||||
#![deny(warnings)]
|
||||
#![no_main]
|
||||
#![no_std]
|
||||
|
||||
use panic_semihosting as _;
|
||||
|
||||
#[rtic::app(device = lm3s6965, dispatchers = [GPIOA])]
|
||||
mod app {
|
||||
use cortex_m_semihosting::{debug, hprintln};
|
||||
|
||||
#[shared]
|
||||
struct Shared {
|
||||
shared1: u32,
|
||||
shared2: u32,
|
||||
shared3: u32,
|
||||
}
|
||||
|
||||
#[local]
|
||||
struct Local {}
|
||||
|
||||
#[init]
|
||||
fn init(_: init::Context) -> (Shared, Local, init::Monotonics) {
|
||||
locks::spawn().unwrap();
|
||||
|
||||
(
|
||||
Shared {
|
||||
shared1: 0,
|
||||
shared2: 0,
|
||||
shared3: 0,
|
||||
},
|
||||
Local {},
|
||||
init::Monotonics(),
|
||||
)
|
||||
}
|
||||
|
||||
// when omitted priority is assumed to be `1`
|
||||
#[task(shared = [shared1, shared2, shared3])]
|
||||
fn locks(c: locks::Context) {
|
||||
// nested multi-lock
|
||||
let mut s1 = c.shared.shared1;
|
||||
let mut s2 = c.shared.shared2;
|
||||
let mut s3 = c.shared.shared3;
|
||||
|
||||
(&mut s1, &mut s2, &mut s3).lock(|s1, s2, s3| {
|
||||
*s1 += 1;
|
||||
*s2 += 2;
|
||||
*s3 += 3;
|
||||
|
||||
hprintln!("Multiple locks, s1: {}, s2: {}, s3: {}", s1, s2, s3).ok();
|
||||
});
|
||||
|
||||
// re-construct gives error (consumed by above lock)
|
||||
let s = locks::SharedResources {
|
||||
shared1: s1,
|
||||
shared2: s2,
|
||||
shared3: s3,
|
||||
};
|
||||
|
||||
// nested multi-lock destruct
|
||||
let locks::SharedResources {
|
||||
shared1,
|
||||
shared2,
|
||||
shared3,
|
||||
} = s;
|
||||
|
||||
(shared1, shared2, shared3).lock(|s1, s2, s3| {
|
||||
*s1 += 1;
|
||||
*s2 += 2;
|
||||
*s3 += 3;
|
||||
|
||||
hprintln!("Multiple locks, s1: {}, s2: {}, s3: {}", s1, s2, s3).ok();
|
||||
});
|
||||
|
||||
debug::exit(debug::EXIT_SUCCESS); // Exit QEMU simulator
|
||||
}
|
||||
}
|
Loading…
Reference in a new issue