mutex

Author: monnetchr

course/src/main.rs

@@ -3,6 +3,7 @@ use myutils::stuff;
 use myutils::testing;
 //use guessgame
 use paral::channels;
+use paral::mutex;
 use paral::threads;
 
 fn main() {
@@ -18,4 +19,5 @@ fn main() {
     intmut::weakrefs();
     threads::demo();
     channels::demo();
+    mutex::demo();
 }

paral/src/channels.rs

@@ -14,7 +14,7 @@ pub fn demo() {
         ];
         for val in vals {
             tx.send(val).unwrap();
-            thread::sleep(std::time::Duration::from_secs(1));
+            thread::sleep(std::time::Duration::from_secs_f32(0.1));
         }
     });
 
@@ -27,7 +27,7 @@ pub fn demo() {
         ];
         for val in vals {
             tx2.send(val).unwrap();
-            thread::sleep(std::time::Duration::from_secs(1));
+            thread::sleep(std::time::Duration::from_secs_f32(0.1));
         }
     });
 

paral/src/lib.rs

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

paral/src/mutex.rs

@@ -0,0 +1,29 @@
+use std::sync::{Arc, Mutex};
+use std::thread;
+
+pub fn demo() {
+    println!("Mutex");
+    let m = Mutex::new(5);
+    {
+        let mut num = m.lock().unwrap();
+        *num = 6;
+    }
+    println!("m = {:?}", m);
+
+    let counter = Arc::new(Mutex::new(0));
+    let mut handles = vec![];
+    for _ in 0..10 {
+        let counter = Arc::clone(&counter);
+        let handle = thread::spawn({
+            move || {
+                let mut num = counter.lock().unwrap();
+                *num += 1;
+            }
+        });
+        handles.push(handle);
+    }
+    for handle in handles {
+        handle.join().unwrap();
+    }
+    println!("Result: {}", *counter.lock().unwrap());
+}