diff options
Diffstat (limited to 'examples/nrf/src/bin')
| -rw-r--r-- | examples/nrf/src/bin/multiprio.rs | 10 | ||||
| -rw-r--r-- | examples/nrf/src/bin/self_spawn.rs | 24 |
2 files changed, 28 insertions, 6 deletions
diff --git a/examples/nrf/src/bin/multiprio.rs b/examples/nrf/src/bin/multiprio.rs index e69f87d85..54f6606a9 100644 --- a/examples/nrf/src/bin/multiprio.rs +++ b/examples/nrf/src/bin/multiprio.rs | |||
| @@ -124,17 +124,15 @@ fn main() -> ! { | |||
| 124 | let irq = interrupt::take!(SWI1_EGU1); | 124 | let irq = interrupt::take!(SWI1_EGU1); |
| 125 | irq.set_priority(interrupt::Priority::P6); | 125 | irq.set_priority(interrupt::Priority::P6); |
| 126 | let executor = EXECUTOR_HIGH.put(InterruptExecutor::new(irq)); | 126 | let executor = EXECUTOR_HIGH.put(InterruptExecutor::new(irq)); |
| 127 | executor.start(|spawner| { | 127 | let spawner = executor.start(); |
| 128 | unwrap!(spawner.spawn(run_high())); | 128 | unwrap!(spawner.spawn(run_high())); |
| 129 | }); | ||
| 130 | 129 | ||
| 131 | // Medium-priority executor: SWI0_EGU0, priority level 7 | 130 | // Medium-priority executor: SWI0_EGU0, priority level 7 |
| 132 | let irq = interrupt::take!(SWI0_EGU0); | 131 | let irq = interrupt::take!(SWI0_EGU0); |
| 133 | irq.set_priority(interrupt::Priority::P7); | 132 | irq.set_priority(interrupt::Priority::P7); |
| 134 | let executor = EXECUTOR_MED.put(InterruptExecutor::new(irq)); | 133 | let executor = EXECUTOR_MED.put(InterruptExecutor::new(irq)); |
| 135 | executor.start(|spawner| { | 134 | let spawner = executor.start(); |
| 136 | unwrap!(spawner.spawn(run_med())); | 135 | unwrap!(spawner.spawn(run_med())); |
| 137 | }); | ||
| 138 | 136 | ||
| 139 | // Low priority executor: runs in thread mode, using WFE/SEV | 137 | // Low priority executor: runs in thread mode, using WFE/SEV |
| 140 | let executor = EXECUTOR_LOW.put(Executor::new()); | 138 | let executor = EXECUTOR_LOW.put(Executor::new()); |
diff --git a/examples/nrf/src/bin/self_spawn.rs b/examples/nrf/src/bin/self_spawn.rs new file mode 100644 index 000000000..35e73a8dd --- /dev/null +++ b/examples/nrf/src/bin/self_spawn.rs | |||
| @@ -0,0 +1,24 @@ | |||
| 1 | #![no_std] | ||
| 2 | #![no_main] | ||
| 3 | #![feature(type_alias_impl_trait)] | ||
| 4 | |||
| 5 | use defmt::{info, unwrap}; | ||
| 6 | use embassy::executor::Spawner; | ||
| 7 | use embassy::time::{Duration, Timer}; | ||
| 8 | use embassy_nrf::Peripherals; | ||
| 9 | |||
| 10 | use defmt_rtt as _; // global logger | ||
| 11 | use panic_probe as _; | ||
| 12 | |||
| 13 | #[embassy::task(pool_size = 2)] | ||
| 14 | async fn my_task(spawner: Spawner, n: u32) { | ||
| 15 | Timer::after(Duration::from_secs(1)).await; | ||
| 16 | info!("Spawning self! {}", n); | ||
| 17 | unwrap!(spawner.spawn(my_task(spawner, n + 1))); | ||
| 18 | } | ||
| 19 | |||
| 20 | #[embassy::main] | ||
| 21 | async fn main(spawner: Spawner, _p: Peripherals) { | ||
| 22 | info!("Hello World!"); | ||
| 23 | unwrap!(spawner.spawn(my_task(spawner, 0))); | ||
| 24 | } | ||
