add more examples

Author: smallnest

asyncwait/src/main.rs

@@ -11,6 +11,7 @@ fn main() {
 
     join();
     select();
+    futures_select();
 
     stream();
 

asyncwait/src/runtimes.rs

@@ -1,4 +1,3 @@
-
 use futures::channel::mpsc;
 use futures::executor::{self, ThreadPool};
 use futures::try_join;
@@ -9,7 +8,6 @@ use futures::{
     select,
 };
 
-
 pub fn tokio_async() {
     let rt = tokio::runtime::Runtime::new().unwrap();
     rt.block_on(async {
@@ -94,3 +92,23 @@ pub fn select() {
         }
     });
 }
+
+pub fn futures_select() {
+    futures_lite::future::block_on(async {
+        use futures::future;
+
+        let mut a_fut = future::ready(4);
+        let mut b_fut = future::ready(6);
+        let mut total = 0;
+
+        loop {
+            select! {
+                a = a_fut => total += a,
+                b = b_fut => total += b,
+                complete => {println!("complete"); break},
+                default => unreachable!(), // never runs (futures are ready, then complete)
+            };
+        }
+        assert_eq!(total, 10);
+    });
+}

channel/Cargo.toml

@@ -12,5 +12,7 @@ atomic_mpmc = "0.2.0"
 broadcaster = "1.0.0"
 crossfire = "0.1.7"
 flume = "0.10.14"
+futures = "0.3.24"
+futures-channel = "0.3.24"
 futures-util = "0.3.24"
 tokio = { version = "1.21.2", features = ["full"] }

channel/src/lib.rs

@@ -59,4 +59,4 @@ pub fn mpsc_example4() {
     }
 
     println!("mpsc_example4 completed");
-}
+}

channel/src/main.rs

@@ -12,4 +12,6 @@ fn main() {
     flume_example();
     async_channel_example();
     async_priority_channel_example();
+    futures_channel_mpsc_example();
+    futures_channel_oneshot_example();
 }

channel/src/others.rs

@@ -163,6 +163,51 @@ pub fn async_channel_example() {
     });
 }
 
+pub fn futures_channel_mpsc_example() {
+    let rt = tokio::runtime::Runtime::new().unwrap();
+
+    let (tx, mut rx) = futures_channel::mpsc::channel(3);
+
+    rt.block_on(async move {
+        tokio::spawn(async move {
+            for _ in 0..3 {
+                let mut tx = tx.clone();
+                thread::spawn(move || tx.start_send("ok"));
+            }
+
+            drop(tx);
+        });
+
+        // Unbounded receiver waiting for all senders to complete.
+        while let Ok(msg) = rx.try_next() {
+            println!("{:?}", msg);
+        }
+
+        println!("futures_channel_mpsc_example completed");
+    });
+}
+
+pub fn futures_channel_oneshot_example() {
+    use futures::channel::oneshot;
+    use std::time::Duration;
+
+    let (sender, receiver) = oneshot::channel::<i32>();
+
+    thread::spawn(|| {
+        println!("THREAD: sleeping zzz...");
+        thread::sleep(Duration::from_millis(1000));
+        println!("THREAD: i'm awake! sending.");
+        sender.send(3).unwrap();
+    });
+
+    println!("MAIN: doing some useful stuff");
+
+    futures::executor::block_on(async {
+        println!("MAIN: waiting for msg...");
+        println!("MAIN: got: {:?}", receiver.await)
+    });
+}
+
 pub fn async_priority_channel_example() {
     let rt = tokio::runtime::Runtime::new().unwrap();