1 files changed, 72 insertions, 0 deletions
diff --git a/crates/qemu/src/main.rs b/crates/qemu/src/main.rs
new file mode 100644
index 0000000..3a3df38
--- /dev/null
+++ b/crates/qemu/src/main.rs
@@ -0,0 +1,72 @@
+use rust_threadx_qemu::exit_success;
+use std::{
+    sync::{Arc, Condvar, Mutex},
+    time::Duration,
+};
+
+fn main() {
+    println!("Hello, world!");
+    println!("Testing allocations in 0.25 seconds...");
+    std::thread::sleep(Duration::from_millis(250));
+    test_heap_allocation();
+
+    let mtx = Arc::new(Mutex::new(0_u32));
+    let cv = Arc::new(Condvar::new());
+
+    std::thread::scope(|s| {
+        s.spawn(|| {
+            println!("Hello from one thread!");
+            let mut guard = mtx.lock().unwrap();
+            *guard += 1;
+            cv.notify_all();
+        });
+    });
+
+    let (m, c) = (mtx.clone(), cv.clone());
+    std::thread::spawn(move || {
+        println!("Hello from another thread!");
+
+        let guard = m.lock().unwrap();
+        let mut guard = c.wait_while(guard, |c| *c != 1).unwrap();
+        *guard += 1;
+        c.notify_all();
+    })
+    .join()
+    .unwrap();
+
+    let guard = mtx.lock().unwrap();
+    let guard = cv.wait_while(guard, |c| *c != 2).unwrap();
+    assert_eq!(*guard, 2);
+
+    echo_stdin();
+    exit_success();
+}
+
+fn echo_stdin() {
+    use std::io::{self, Write};
+
+    print!("Enter a message: ");
+    // `print!` does not flush, so make sure the prompt reaches the host before
+    // we block waiting on input.
+    io::stdout().flush().ok();
+
+    let mut message = String::new();
+    match io::stdin().read_line(&mut message) {
+        Ok(0) => println!("No message received (EOF)"),
+        Ok(_) => println!("You said: {}", message.trim_end()),
+        Err(e) => println!("Failed to read message: {e}"),
+    }
+}
+
+fn test_heap_allocation() {
+    use core::hint::black_box;
+
+    for len in [32usize, 64, 128] {
+        let mut v: Vec<usize> = Vec::with_capacity(len);
+        for i in 0..len {
+            v.push(black_box(i));
+        }
+        let v = black_box(v);
+        println!("Allocated vector with {} elements", v.len());
+    }
+}