add more examples

smallnest · smallnest · commit 65a8620a4974 · 2022-10-11T19:35:31.000+08:00
diff --git a/Cargo.toml b/Cargo.toml
@@ -1,2 +1,2 @@
 [workspace]
-members = ["thread", "pool", "asyncwait", "primitive", "collections", "process", "syncs", "channel","parking_lot_examples", "crossbeam_examples", "special"]
+members = ["thread", "pool", "asyncwait", "primitive", "collections", "process", "syncs", "channel", "timer_examples", "parking_lot_examples", "crossbeam_examples", "rayon_examples", "tokio_examples", "special"]
diff --git a/README.md b/README.md
@@ -5,7 +5,7 @@
 
 ## chapter 2: Thread Pool
 
-## chapter 3: async
+## chapter 3: async/.await
 
 ## chapter 4: synchronization primitives
 
@@ -15,13 +15,15 @@
 
 ## chapter 7: channel
 
-## chapter 8: parking_lot
+## chapter 8: timer/ticker
 
-## chapter 9: crossbeam
+## chapter 9: parking_lot
 
-## chapter 10: xxxx
+## chapter 10: crossbeam
 
-## chapter 11: xxxx
+## chapter 11: rayon
+
+## chapter 12: tokio
 
 ## chapter n: special
 
diff --git a/rayon_examples/Cargo.toml b/rayon_examples/Cargo.toml
@@ -0,0 +1,8 @@
+[package]
+name = "rayon_examples"
+version = "0.1.0"
+edition = "2021"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
diff --git a/rayon_examples/src/main.rs b/rayon_examples/src/main.rs
@@ -0,0 +1,3 @@
+fn main() {
+    println!("Hello, world!");
+}
diff --git a/special/src/lib.rs b/special/src/lib.rs
@@ -1,3 +1,7 @@
 pub mod oslock;
+pub mod oneshot;
+pub mod map;
 
-pub use oslock::*;
+pub use oslock::*;
+pub use oneshot::*;
+pub use map::*;
diff --git a/special/src/map.rs b/special/src/map.rs
diff --git a/special/src/mco.rs b/special/src/mco.rs
@@ -0,0 +1,2 @@
+// singleflight
+// async-singleflight
diff --git a/special/src/oneshot.rs b/special/src/oneshot.rs
@@ -0,0 +1,2 @@
+// oneshot
+// catty
diff --git a/special/src/primitive.rs b/special/src/primitive.rs
@@ -0,0 +1,12 @@
+// Mutex
+// RWLock
+// wg
+// async-xxx
+// awaitgroup
+// usync
+
+
+// waitfor
+
+// atomig
+// atomicbox
diff --git a/special/src/scc.rs b/special/src/scc.rs
@@ -0,0 +1 @@
+// scc
diff --git a/syncs/Cargo.toml b/syncs/Cargo.toml
@@ -6,4 +6,4 @@ edition = "2021"
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
-rand = "0.8.5"
+rand = "0.8.5"
diff --git a/syncs/src/lib.rs b/syncs/src/lib.rs
@@ -8,7 +8,6 @@ pub mod barrier;
 pub mod cond;
 pub mod mpsc;
 pub mod atomic;
- 
 
 pub use arc::*;
 pub use mutex::*;
diff --git a/timer_examples/Cargo.toml b/timer_examples/Cargo.toml
@@ -0,0 +1,13 @@
+[package]
+name = "timer_examples"
+version = "0.1.0"
+edition = "2021"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
+chrono = "0.4.22"
+safina-timer = "0.1.11"
+smol = "1.2.5"
+ticker = "0.1.1"
+timer = "0.2.0"
diff --git a/timer_examples/src/lib.rs b/timer_examples/src/lib.rs
@@ -0,0 +1,5 @@
+pub mod timers;
+pub mod tickers;
+ 
+pub use timers::*;
+pub use tickers::*;
diff --git a/timer_examples/src/main.rs b/timer_examples/src/main.rs
@@ -0,0 +1,9 @@
+use timer_examples::*;
+
+fn main() {
+    timer_schedule_with_delay();
+    timer_schedule_with_date();
+    timer_repeat();
+
+    safina_timer_example();
+}
diff --git a/timer_examples/src/tickers.rs b/timer_examples/src/tickers.rs
@@ -0,0 +1,9 @@
+use ticker::Ticker;
+use std::time::Duration;
+
+pub fn ticker_example() {
+    let ticker = Ticker::new(0..10, Duration::from_secs(1));
+    for i in ticker {
+        println!("{:?}", i)
+    }
+}
diff --git a/timer_examples/src/timers.rs b/timer_examples/src/timers.rs
@@ -0,0 +1,86 @@
+use std::ops::Add;
+use std::sync::mpsc::channel;
+use std::sync::Arc;
+use std::sync::Mutex;
+use std::thread;
+
+use chrono::{self, Local};
+use timer;
+
+pub fn timer_schedule_with_delay() {
+    let timer = timer::Timer::new();
+    let (tx, rx) = channel();
+
+    let _guard = timer.schedule_with_delay(chrono::Duration::seconds(3), move || {
+        // This closure is executed on the scheduler thread,
+        // so we want to move it away asap.
+
+        let _ignored = tx.send(()); // Avoid unwrapping here.
+    });
+
+    rx.recv().unwrap();
+    println!("This code has been executed after 3 seconds");
+}
+
+pub fn timer_schedule_with_date() {
+    let timer = timer::Timer::new();
+    let (tx, rx) = channel();
+
+    let _guard =
+        timer.schedule_with_date(Local::now().add(chrono::Duration::seconds(1)), move || {
+            // This closure is executed on the scheduler thread,
+            // so we want to move it away asap.
+
+            let _ignored = tx.send(()); // Avoid unwrapping here.
+        });
+
+    rx.recv().unwrap();
+    println!("This code has been executed after 1 seconds");
+}
+
+pub fn timer_repeat() {
+    let timer = timer::Timer::new();
+    // Number of times the callback has been called.
+    let count = Arc::new(Mutex::new(0));
+
+    // Start repeating. Each callback increases `count`.
+    let guard = {
+        let count = count.clone();
+        timer.schedule_repeating(chrono::Duration::milliseconds(5), move || {
+            *count.lock().unwrap() += 1;
+        })
+    };
+
+    // Sleep one second. The callback should be called ~200 times.
+    thread::sleep(std::time::Duration::new(1, 0));
+    let count_result = *count.lock().unwrap();
+    assert!(
+        190 <= count_result && count_result <= 210,
+        "The timer was called {} times",
+        count_result
+    );
+
+    // Now drop the guard. This should stop the timer.
+    drop(guard);
+    thread::sleep(std::time::Duration::new(0, 100));
+
+    // Let's check that the count stops increasing.
+    let count_start = *count.lock().unwrap();
+    thread::sleep(std::time::Duration::new(1, 0));
+    let count_stop = *count.lock().unwrap();
+    assert_eq!(count_start, count_stop);
+}
+
+pub fn safina_timer_example() {
+    smol::block_on(async {
+        safina_timer::start_timer_thread();
+        let duration = std::time::Duration::from_secs(1);
+        safina_timer::sleep_for(duration).await;
+    });
+
+    smol::block_on(async {
+        safina_timer::start_timer_thread();
+        let deadline = std::time::Instant::now() + std::time::Duration::from_secs(1);
+        safina_timer::sleep_until(deadline).await;
+    });
+}
diff --git a/tokio_examples/Cargo.toml b/tokio_examples/Cargo.toml
@@ -0,0 +1,8 @@
+[package]
+name = "tokio_examples"
+version = "0.1.0"
+edition = "2021"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
diff --git a/tokio_examples/src/main.rs b/tokio_examples/src/main.rs
@@ -0,0 +1,3 @@
+fn main() {
+    println!("Hello, world!");
+}

Original file line number	Diff line number	Diff line change
`@@ -1,2 +1,2 @@`
`1`	`1`	`[workspace]`
`2`		`-members = ["thread", "pool", "asyncwait", "primitive", "collections", "process", "syncs", "channel","parking_lot_examples", "crossbeam_examples", "special"]`
	`2`	`+members = ["thread", "pool", "asyncwait", "primitive", "collections", "process", "syncs", "channel", "timer_examples", "parking_lot_examples", "crossbeam_examples", "rayon_examples", "tokio_examples", "special"]`
Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,3 @@`
	`1`	`+fn main() {`
	`2`	`+ println!("Hello, world!");`
	`3`	`+}`
Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,2 @@`
	`1`	`+// singleflight`
	`2`	`+// async-singleflight`