From 4432159af4b727bf1fc1ae06f5d04816b14544d0 Mon Sep 17 00:00:00 2001
From: meloalright <meloalright@gmail.com>
Date: Sat, 16 Nov 2024 17:12:34 +0800
Subject: [PATCH] feat(example): add examples of async

---
 examples/async.rs              | 92 ++++++++++++++++++++++++++++++++++
 examples/{hello.rs => demo.rs} |  0
 src/lib.rs                     |  4 ++
 3 files changed, 96 insertions(+)
 rename examples/{hello.rs => demo.rs} (100%)

diff --git a/examples/async.rs b/examples/async.rs
index e69de29..758c663 100644
--- a/examples/async.rs
+++ b/examples/async.rs
@@ -0,0 +1,92 @@
+use std::thread;
+use std::sync::{Arc, Mutex, RwLock};
+use taitank_safe::*;
+
+fn main() {
+    {
+        /// Arc
+        let mut root = node_create();
+        set_width(&mut root, 200.0);
+
+        layout!(&mut root);
+
+        let arc_root = Arc::new(root);
+        let mut handles = vec![];
+
+        for i in 0..5 {
+            let arc_root = Arc::clone(&arc_root);
+            let handle = thread::spawn(move || {
+                println!("Arc {}", i);
+                println!("{:?}", arc_root);
+            });
+            handles.push(handle);
+        }
+        for handle in handles {
+            handle.join().unwrap();
+        }
+    }
+    {
+        /// RwLock
+        let mut root = node_create();
+        set_width(&mut root, 200.0);
+
+        layout!(&mut root);
+
+        let arc_rwlock_root = Arc::new(RwLock::new(root));
+        let mut handles = vec![];
+
+        for i in 0..5 {
+            let arc_rwlock_root = Arc::clone(&arc_rwlock_root);
+            let handle = thread::spawn(move || {
+                let root = arc_rwlock_root.read().unwrap();
+                let width = get_width(&root);
+                drop(root);
+                let mut root = arc_rwlock_root.write().unwrap();
+                set_width(&mut root, width + 10.0);
+                layout!(&mut root);
+                println!("RwLock {}", i);
+                println!("{:?}", root);
+            });
+            handles.push(handle);
+        }
+
+        for handle in handles {
+            handle.join().unwrap();
+        }
+
+        let final_data = arc_rwlock_root.read().unwrap();
+        println!("RwLock final");
+        println!("{:?}", final_data);
+    }
+    {
+        /// Mutex
+        let mut root = node_create();
+        set_width(&mut root, 200.0);
+        layout!(&mut root);
+
+        let arc_mutex_root = Arc::new(Mutex::new(root));
+        let mut handles = vec![];
+
+        for i in 0..5 {
+            let arc_mutex_root = Arc::clone(&arc_mutex_root);
+            let handle = thread::spawn(move || {
+                // 获取 Mutex 的锁并修改数据
+                let mut root = arc_mutex_root.lock().unwrap();
+                let width = get_width(&root);
+                set_width(&mut root, width + 10.0);
+                layout!(&mut root);
+                println!("Mutex {}", i);
+                println!("{:?}", root);
+            });
+            handles.push(handle);
+        }
+
+        for handle in handles {
+            handle.join().unwrap();
+        }
+
+        let final_data = arc_mutex_root.lock().unwrap();
+        println!("Mutex final");
+        println!("{:?}", final_data);
+    }
+}
\ No newline at end of file
diff --git a/examples/hello.rs b/examples/demo.rs
similarity index 100%
rename from examples/hello.rs
rename to examples/demo.rs
diff --git a/src/lib.rs b/src/lib.rs
index cbc5c13..c056b7e 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -15,6 +15,10 @@ impl Debug for TaitankSafeNode {
     }
 }
 
+unsafe impl Send for TaitankSafeNode {}
+unsafe impl Sync for TaitankSafeNode {}
+
+
 #[repr(i32)]
 pub enum Direction {
     Inherit = 0,