channels

Author: monnetchr

course/src/main.rs

@@ -2,6 +2,7 @@ use basics;
 use myutils::stuff;
 use myutils::testing;
 //use guessgame
+use paral::channels;
 use paral::threads;
 
 fn main() {
@@ -16,4 +17,5 @@ fn main() {
     intmut::intmut();
     intmut::weakrefs();
     threads::demo();
+    channels::demo();
 }

paral/src/channels.rs

@@ -0,0 +1,37 @@
+use std::{sync::mpsc, thread};
+
+pub fn demo() {
+    println!("Channels");
+    let (tx, rx) = mpsc::channel();
+    let tx2 = tx.clone();
+
+    thread::spawn(move || {
+        let vals = vec![
+            String::from("hi"),
+            String::from("from"),
+            String::from("the"),
+            String::from("thread"),
+        ];
+        for val in vals {
+            tx.send(val).unwrap();
+            thread::sleep(std::time::Duration::from_secs(1));
+        }
+    });
+
+    thread::spawn(move || {
+        let vals = vec![
+            String::from("more"),
+            String::from("messages"),
+            String::from("for"),
+            String::from("you"),
+        ];
+        for val in vals {
+            tx2.send(val).unwrap();
+            thread::sleep(std::time::Duration::from_secs(1));
+        }
+    });
+
+    for received in rx {
+        println!("Got: {}", received);
+    }
+}

paral/src/lib.rs

@@ -1 +1,2 @@
+pub mod channels;
 pub mod threads;

paral/src/threads.rs

@@ -3,7 +3,7 @@ use std::{thread, time::Duration};
 pub fn demo() {
     println!("Threads");
     let handle = thread::spawn(|| {
-        for i in 1..10 {
+        for i in 1..5 {
             println!("hi number {} from the spawned thread!", i);
             thread::sleep(Duration::from_millis(1));
         }
@@ -13,9 +13,7 @@ pub fn demo() {
 
     let v = vec![1, 2, 3];
     let handle = thread::spawn(move || {
-        for i in 1..10 {
-            println!("{}: Here's a vector: {:?}", i, v);
-        }
+        println!("Here's a vector: {:?}", v);
     });
     handle.join().unwrap();
 }