add more examples

Author: smallnest

special/Cargo.toml

@@ -9,7 +9,10 @@ edition = "2021"
 async-lock = "2.5.0"
 async-oneshot = "0.5.0"
 atomic_float = "0.1.0"
+atomicbox = "0.4.0"
+atomig = "0.4.0"
 awaitgroup = "0.6.0"
+barrage = "0.2.3"
 catty = "0.1.5"
 concurrent-queue = "1.2.4"
 dashmap = "5.4.0"

special/src/main.rs

@@ -13,13 +13,15 @@ fn main() {
 
     event_listener_example();
     triggered_example();
-
+    barrage_example();
+    
     hashmap_example();
     flurry_hashmap();
     flurry_hashset();
     evmap_example();
 
     concurrent_queue_example();
+    triple_buffer_example();
 
     async_lock_mutex();
     async_lock_rwlock();
@@ -30,6 +32,8 @@ fn main() {
     portable_atomic_u128();
     portable_atomic_f64();
     atomic_float_example();
+    atomig_example();
+    atomicbox_examples();
 
     simple_mutex_example();
 

special/src/notify.rs

@@ -64,3 +64,13 @@ pub fn triggered_example() {
         let _ = task.await;
     })
 }
+
+pub fn barrage_example() {
+    smol::block_on(async {
+        let (tx, rx) = barrage::unbounded();
+        let rx2 = rx.clone();
+        tx.send_async("Hello!").await.unwrap();
+        assert_eq!(rx.recv_async().await, Ok("Hello!"));
+        assert_eq!(rx2.recv_async().await, Ok("Hello!"));
+    });
+}

special/src/primitive/atomic_examples.rs

@@ -1,4 +1,7 @@
+use atomicbox::AtomicBox;
+use atomig::Atomic;
 use portable_atomic::*;
+use std::sync::atomic::Ordering;
 use std::sync::atomic::Ordering::Relaxed;
 
 pub fn portable_atomic_i128() {
@@ -52,3 +55,20 @@ pub fn atomic_float_example() {
 
     assert_eq!(some_var.load(Relaxed), -885.0);
 }
+
+pub fn atomig_example() {
+    let some_var = Atomic::new(0);
+    some_var.store(800, Relaxed);
+
+    some_var.fetch_add(30, Relaxed);
+    some_var.fetch_sub(-55, Relaxed);
+
+    assert_eq!(some_var.load(Relaxed), 885);
+}
+
+pub fn atomicbox_examples() {
+    let atom = AtomicBox::new(Box::new("one"));
+    let mut boxed = Box::new("two");
+    atom.swap_mut(&mut boxed, Ordering::AcqRel);
+    assert_eq!(*boxed, "one");
+}

special/src/queue.rs

@@ -1,6 +1,8 @@
 use concurrent_queue::ConcurrentQueue;
-use std::thread;
 use std::sync::Arc;
+use std::thread;
+
+use triple_buffer::triple_buffer;
 
 pub fn concurrent_queue_example() {
     let q = Arc::new(ConcurrentQueue::unbounded());
@@ -13,17 +15,31 @@ pub fn concurrent_queue_example() {
     });
 
     let q2 = q.clone();
-    let rhandle = thread::spawn(move || {
-        loop {
-            if let Ok(v) = q2.pop() {
-                println!("get value {}", v);
-            } else {
-                println!("queue closed");
-                break;
-            }
+    let rhandle = thread::spawn(move || loop {
+        if let Ok(v) = q2.pop() {
+            println!("get value {}", v);
+        } else {
+            println!("queue closed");
+            break;
         }
     });
 
     whandle.join().unwrap();
     rhandle.join().unwrap();
 }
+
+pub fn triple_buffer_example() {
+    let (mut buf_input, mut buf_output) = triple_buffer(&0);
+
+    // The producer thread can move a value into the buffer at any time
+    let producer = std::thread::spawn(move || buf_input.write(42));
+
+    // The consumer thread can read the latest value at any time
+    let consumer = std::thread::spawn(move || {
+        let latest = buf_output.read();
+        assert!(*latest == 42 || *latest == 0);
+    });
+
+    producer.join().unwrap();
+    consumer.join().unwrap();
+}