summaryrefslogtreecommitdiff
path: root/components/rust/examples/application/semaphore/src
diff options
context:
space:
mode:
Diffstat (limited to 'components/rust/examples/application/semaphore/src')
-rw-r--r--components/rust/examples/application/semaphore/src/lib.rs50
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!")
+ }
+ });
+}
+