episode 16

Author: Byron

Cargo.lock

@@ -1,2 +1,2 @@
 [workspace]
-members = ["./ownership-and-borrowing", "options-and-results", "errors", "iterators", "strings", "boxing", "conversions", "closures"]
+members = ["./ownership-and-borrowing", "options-and-results", "errors", "iterators", "strings", "boxing", "conversions", "closures", "threading"]

Cargo.toml

@@ -29,12 +29,12 @@ fn main() {
     dbg!(count);
 
     struct Closure<'a> {
-        count: &'a mut u32,
+        val: Rc<Vec<u32>>,
     }
     impl<'a> Closure<'a> {
         fn call(&mut self) -> u32 {
-            self.count.add_assign(1);
-            *self.count
+            self.val.add_assign(1);
+            *self.val
         }
     }
 }

closures/src/main.rs

@@ -0,0 +1,8 @@
+[package]
+name = "threading"
+version = "0.1.0"
+edition = "2021"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]

threading/Cargo.toml

@@ -0,0 +1,32 @@
+#![allow(unused)]
+
+use std::cell::RefCell;
+use std::sync::{Arc, Mutex};
+
+fn main() {
+    let val = Arc::new(vec![42, 10]);
+    let mut change = Arc::new(Mutex::new(52));
+    let t = vec![
+        std::thread::spawn({
+            let val = Arc::clone(&val);
+            let change = change.clone();
+            move || {
+                println!("work: {}", val[0]);
+                *change.lock().unwrap() += 10;
+            }
+        }),
+        std::thread::spawn({
+            let val = val.clone();
+            move || {
+                println!("work: {}", val[1]);
+            }
+        }),
+    ];
+    dbg!(&val);
+
+    println!("other work");
+    for thread in t {
+        println!("{:?}", thread.join().unwrap());
+    }
+    dbg!(change);
+}