diff options
Diffstat (limited to 'components/rust/examples/application/semaphore/src')
| -rw-r--r-- | components/rust/examples/application/semaphore/src/lib.rs | 50 |
1 files changed, 50 insertions, 0 deletions
diff --git a/components/rust/examples/application/semaphore/src/lib.rs b/components/rust/examples/application/semaphore/src/lib.rs new file mode 100644 index 0000000000..986acd1957 --- /dev/null +++ b/components/rust/examples/application/semaphore/src/lib.rs @@ -0,0 +1,50 @@ +/* + * Copyright (c) 2006-2025, RT-Thread Development Team + * + * SPDX-License-Identifier: Apache-2.0 + * + * Change Logs: + * Date Author notes + * 2025-10-10 foxglove semaphore test demo + * 2025-10-29 foxglove Updated to demonstrate new modular macro interface + */ +#![no_std] + +extern crate alloc; + +use alloc::sync::Arc; +use core::time::Duration; +use rt_macros::msh_cmd_export; +use rt_rust::sem::Semaphore; +use rt_rust::param::Param; +use rt_rust::println; +use rt_rust::thread; +use rt_rust::time; + +#[msh_cmd_export(name = "rust_sem_demo", desc = "Rust example app.")] +fn main(_param: Param) { + let send = Arc::new(Semaphore::new().unwrap()); + let recv = send.clone(); + + let _ = thread::Thread::new() + .name("thread 1") + .stack_size(1024) + .start(move || { + loop { + time::sleep(Duration::new(1, 0)); + send.release() + } + }); + time::sleep(Duration::new(1, 0)); + let _ = thread::Thread::new() + .name("thread 2") + .stack_size(1024) + .start(move || { + loop { + println!("waiting!"); + recv.take_wait_forever().unwrap(); + println!("recv a sem!") + } + }); +} + |
