diff options
Diffstat (limited to 'examples/nrf52840/src/bin/executor_fairness_test.rs')
| -rw-r--r-- | examples/nrf52840/src/bin/executor_fairness_test.rs | 43 |
1 files changed, 43 insertions, 0 deletions
diff --git a/examples/nrf52840/src/bin/executor_fairness_test.rs b/examples/nrf52840/src/bin/executor_fairness_test.rs new file mode 100644 index 000000000..2a28f2763 --- /dev/null +++ b/examples/nrf52840/src/bin/executor_fairness_test.rs | |||
| @@ -0,0 +1,43 @@ | |||
| 1 | #![no_std] | ||
| 2 | #![no_main] | ||
| 3 | #![feature(type_alias_impl_trait)] | ||
| 4 | |||
| 5 | use core::future::poll_fn; | ||
| 6 | use core::task::Poll; | ||
| 7 | |||
| 8 | use defmt::{info, unwrap}; | ||
| 9 | use embassy_executor::Spawner; | ||
| 10 | use embassy_time::{Duration, Instant, Timer}; | ||
| 11 | use {defmt_rtt as _, panic_probe as _}; | ||
| 12 | |||
| 13 | #[embassy_executor::task] | ||
| 14 | async fn run1() { | ||
| 15 | loop { | ||
| 16 | info!("DING DONG"); | ||
| 17 | Timer::after(Duration::from_ticks(16000)).await; | ||
| 18 | } | ||
| 19 | } | ||
| 20 | |||
| 21 | #[embassy_executor::task] | ||
| 22 | async fn run2() { | ||
| 23 | loop { | ||
| 24 | Timer::at(Instant::from_ticks(0)).await; | ||
| 25 | } | ||
| 26 | } | ||
| 27 | |||
| 28 | #[embassy_executor::task] | ||
| 29 | async fn run3() { | ||
| 30 | poll_fn(|cx| { | ||
| 31 | cx.waker().wake_by_ref(); | ||
| 32 | Poll::<()>::Pending | ||
| 33 | }) | ||
| 34 | .await; | ||
| 35 | } | ||
| 36 | |||
| 37 | #[embassy_executor::main] | ||
| 38 | async fn main(spawner: Spawner) { | ||
| 39 | let _p = embassy_nrf::init(Default::default()); | ||
| 40 | unwrap!(spawner.spawn(run1())); | ||
| 41 | unwrap!(spawner.spawn(run2())); | ||
| 42 | unwrap!(spawner.spawn(run3())); | ||
| 43 | } | ||
